...
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.
...