2017-11-25 105 views

回答

0

導航到您的bin/windows目錄並使用以下命令之一。

手動添加的消息一個接一個

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

一個

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

與鍵一個手動添加的郵件只需添加parse.keykey.separator性能。該示例使用;,但沒有什麼特別的,可以使用任何其他字符。

自動與鍵

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

該命令將1000封郵件,使用簡單的PowerShell腳本鍵添加多個郵件。