Closed
Description
Description
There are lots of cases where "on Avro schema per topic" does not work. A good description of the cases and solutions available in Java library is provided here:
https://www.confluent.io/blog/put-several-event-types-kafka-topic/
However, the Python library has "subject = topic + key/value" hardcoded, and even the parameter name in encode_record_with_schema
is called topic
, not subject
.
While this behavior could be overriden in subclasses, would be great to have "NameStrategies" compatible/similar to java client implementation.
Metadata
Metadata
Assignees
Labels
No labels