trifecta
trifecta copied to clipboard
[Feature Request] Avro schema registry support (Confluent)
Hi Lawrence, I like what you've done with trifecta. Especially the functionality to dip into and query topics. Would you consider adding support for querying the confluent schema registry to retrieve the avro schema associated with each Kafka messages? (http://www.confluent.io/product). I suspect that a configuration item in config.properties for the repository address would suffice - if the schema repository address is set then always use the schema repo to retrieve the avro schema to decode avro messages.
Thanks for the suggestion, I'll definitely look into providing the support.
Looking into this, it looks like these docs have the instructions to use the registry: http://docs.confluent.io/3.2.0/schema-registry/docs/serializer-formatter.html
@ldaniels528 if I take up this task, would you rather have me modify the existing avro
codec or create a new avro_registry
codec?