I'm currently working with Kafka and Flink, I have kafka running in my local PC and I created a topic that is being consumed.
Desktop\kafka\bin\windows>kafka-console-consumer.bat –zookeeper localhost:2181 -topic test
but it is just retrieving the message,
is there a way to get futher details about the message ? lets say time? key? I checked kafka documentation but I didn't find something about this topic
Best Answer
Using out of the box console consumer (I am using Kafka 0.9.0.1) you can only print the key and the value of messages using different formats. To print the key, set the property
print.key=true
.There is another property
key.separator
that by default is "\t" (a tab) that you can also change to anything you want.To set these properties you can create a config file and use
--consumer.config <config file>
or pass the properties using--property key=value
.You can also implement your own formatter and use it with
--formatter
option but you will still have just the key and value because that is what the MessageFormatter trait provides (see writeTo below).For example: