Kstreams and Schema registry question

2019-10-03 Thread KhajaAsmath Mohammed
Hi, I have kstream in our cluster. I am not sure how the schema is generated for this. Dpes kstream have schema in schema registry? How to move data from kstream to topic which has the same name? How to register schema automatically for this? This is how schema looks in our registry. My

Re: Schema registry question

2016-06-04 Thread Ewen Cheslack-Postava
In any case, to answer the question, I think there's just an omission in the docs. Getting by subject + version (GET /subjects/{subject}/versions/{version} - http://docs.confluent.io/3.0.0/schema-registry/docs/api.html#get--subjects-%28string-%20subject%29-versions-%28versionId-%20version%29) also

Re: Schema registry question

2016-05-23 Thread Avi Flax
Mike, the schema registry you’re using is a part of Confluent’s platform, which builds upon but is not affiliated with Kafka itself. You might want to post your question to Confluent’s mailing list: https://groups.google.com/d/forum/confluent-platform HTH, Avi On 5/20/16, 21:40, "Mike

Schema registry question

2016-05-20 Thread Mike Thomsen
The only method I can seem to find that returns a globally unique ID for a schema is POST /subjects/{subject}/versions Is that true or am I missing something? Was it designed that way because the expectation is that if a producer dies it'll call that service again to ensure that the schema topic