THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
$ kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --property print.partition=true --property print.key=true --property print.timestamp=true --property print.offset=true --property print.headers=true --property key.separator='|' CreateTime:1592475472398|Partition:0|Offset:3|h1=v1,h2=v2|key1|value1 # NOTE: partition 0, offset 3 CreateTime:1592475472456|Partition:0|Offset:4|NO_HEADERS|key2|value2 # NOTE: partition 0, offset 4 |
Proposed Changes
Add new properties to DefaultMessageFormatter
as per the above:
...