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|null|asdf|0|3|h1=v1,h2=v2
CreateTime:1592475472456|null|qwer|0|4|NO_HEADER |
...
Add new properties to DefaultMessageFormatter as per the above:
- print.offsetprint.partition
- print.headers
- header.separator
- headers.deserializer
- null.literal
...