MQTT broker data validation against Schema Registry

Hi Team, I have a requirement where I want MQTT broker to validate the records as per the schema registered in the registry and if it matches then write to the kafka topic or park it in a separate kafka topic. So I was wondering if I can do something like this part of the code with any of the MQT

Console consumer crashing

Hi folks, I was troubleshooting a program trying to receive a kafka message (local kafka, for development), and decided I needed to verify kafka itself was happy. So I created a topic named 'fubar' and started the consumer listening to it. Then I started the console producer in another terminal wi