Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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|key1Partition:0|Offset:3|0|h1=v1,h2=v2|key1|value1    # <-- offset 3NOTE: partition 0, partitionoffset 03
CreateTime:1592475472456|key2Partition:0|Offset:4|0|NO_HEADERS|key2|value2     # <-- offset 4NOTE: partition 0, partitionoffset 04



Proposed Changes

Add new properties to DefaultMessageFormatter as per the above:

...