I do have the next scenario for the kafka messaging:
there are two topics request and response
there are two services coordinator, consumer
coordinator takes care of Avro schemas both for request and response
consumer consumes from the request topic and publishes onto response topic
consumer needs to resolve schema from the schema registry for response topic and encode a message with the obtained schema.
Due to this - encode-function.js needs to be extended with something like byTopic(registry): (topic: string, msg: any, parseOptions?: any)) => Promise<any> to get a schema by a topic name from registry and encode with it.
Hello.
I do have the next scenario for the kafka messaging:
requestandresponsecoordinator,consumercoordinatortakes care of Avro schemas both forrequestandresponseconsumerconsumes from therequesttopic and publishes ontoresponsetopicconsumerneeds to resolve schema from the schema registry forresponsetopic and encode a message with the obtained schema.Due to this -
encode-function.jsneeds to be extended with something likebyTopic(registry): (topic: string, msg: any, parseOptions?: any)) => Promise<any>to get a schema by a topic name from registry and encode with it.@bencebalogh What do you think?