Set :topic for KafkaMessage with SimpleConsumer
Opened this issue · 0 comments
pingles commented
When SimpleConsumer retrieves messages to be mapped to the record KafkaMessage the topic attribute is not available, ensure this is set in the client code.