#Kafka

I have kafka messages defined in protobuf. I want to easily consume the messages. Kafka has a default command line tool called kafka-console-consumer. It has --value-deserializer. If I have a Java deserializer which deserializes kafka messages in protobuf, it should work. However, firstly I don’t want to write extra code. Secondly, --value-deserializer does not work (https://stackoverflow.com/questions/45581082/kafka-console-consumer-sh-custom-deserializer). Confluent has a Schema Registry which allows you to save message schema. However, as of now it supports Avro only. [Read More]