Hi,
I have simple SAM application with one KAFKA Source and KAFKA Sink. after running the App, i got this errors in the streamline.log file:
INFO [2018-09-11 14:46:53.085] [dw-41 - GET /api/v1/schemaregistry/schemas/versionsById/3462796923090514477] c.h.r.s.w.SchemaRegistryResource - No schema version is found with schema version id : [3462796923090514477]
Question : From where SAM get 3462796923090514477 as version ID for the schema, the schema version is 11 not 3462796923090514477.
Error In Storm UI:
Spouts (All time)
| Id | Executors | Tasks | Emitted | Transferred | Complete latency (ms) | Acked | Failed | Error Host | Error Port | Last error | Error Time |
|---|
| 1-KAFKA | 1 | 1 | 0 | 0 | 0.000 | 0 | 0 | sandbox-hdf.hortonworks.com | 6700 | com.hortonworks.registries.schemaregistry.exceptions.RegistryException: java.lang.RuntimeException: com.google.common.util.concurrent.UncheckedExecutionException: javax.ws.rs.NotFoundException: HTTP 4 | Tue, 11 Sep 2018 20:24:27 |
Why SAM use Version ID to Query the Schema from Schema registry. from where it get the Version ID. how can i configure it to use Schema name in the query instead of Version ID.
Thanks ..
