You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently the KafkaError is an Avro object, meaning that anyone using this library needs to have a schema registry on their cluster and use it.
Suggestion
We can create an interface KafkaErrorInterface that requires getters and setters for topic, partition, offset, error stack, message, with the default implementation being the KafkaError avro POJO.
Override could be declared in the properties just like ExceptionHandlers for KafkaStreams.
Alternatives Considered
We could also create a model and their serdes for all 3 main ways of interacting with kafka (Avro, JSON & Protobuff)
The text was updated successfully, but these errors were encountered:
Problem
Currently the KafkaError is an Avro object, meaning that anyone using this library needs to have a schema registry on their cluster and use it.
Suggestion
We can create an interface
KafkaErrorInterface
that requires getters and setters for topic, partition, offset, error stack, message, with the default implementation being the KafkaError avro POJO.Override could be declared in the properties just like ExceptionHandlers for KafkaStreams.
Alternatives Considered
We could also create a model and their serdes for all 3 main ways of interacting with kafka (Avro, JSON & Protobuff)
The text was updated successfully, but these errors were encountered: