THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: ApprovedUnder Discussion
Discussion thread: here
Voting thread: here
...
when parse.headers=true and parse.key=false:
"h1:v1,h2...\tvalue"
when parse.headers=false and parse.key=true:
"key\tvalue"
when parse.headers=false and parse.key=false :
"value"
Code Block |
---|
$ ./bin/kafka-console-producer.sh --bootstrap-server localhost:29092 --topic test --property parse.key=true --property parse.headers=true >h0:v0,h1:v1 key value |
...
Add new properties to ConsoleProducer.LineMessageReader as per the above:
- parse.headerheaders
- headers.delimiter
- headers.separator
- headers.key.separator
...