2017-11-25 2 views

답변

0

bin/windows 디렉토리로 이동하고 다음 명령 중 하나를 사용하십시오.

수동 수동 그냥 parse.keykey.separator 속성을 추가 한

> ./kafka-console-producer.bat --broker-list kafka:9092 --topic test --property "parse.key=true" --property "key.separator=;" 
>key1;value1 
>key2;value2 

에 의해 키 하나 메시지를 추가 한

./kafka-console-producer.bat --broker-list kafka:9092 --topic test 
>value1 
>value2 

하여 메시지 하나를 추가 할 수 있습니다. 이 예제에서는 ;을 사용하지만 특별한 것은 없으며 다른 문자를 사용할 수 있습니다.

자동으로 키

1..1000 | %{"Key$_;Message$_"} | Write-Output | ./kafka-console-producer.bat --property "parse.key=true" --property "key.separator=;" --broker-list kafka:9092 --topic test 

명령은 간단한 PowerShell 스크립트를 사용하여 키 1,000 메시지를 추가로 여러 메시지를 추가합니다.

관련 문제