Versions Compared

Key

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

...

Compatibility, Deprecation, and Migration Plan

This KIP-431 introduces incompatibility when "print.partition=true" (existing argumentthis argument exist before KIP-431 but not documented). Before this KIP, it -431, "kafka-console-consumer" prints the partition as a number after the value for example: "key1|value1|0". After this KIP, it "kafka-console-consumer" prints the partition number prefixed with "Partition:", like " Partition:0" before the key (if printed) and value, for example: "Partition:0|key1|value1" .

The other changes are backward compatible because they do not exist before. Apart from "print.partition=true", if a user does not use any new parameters, then the output of console consumer will look the same as before.

...