卡夫卡快速启动与问题

Question

我下面的快速启动卡夫卡的指示，根据https://kafka.apache.org/quickstart

的饲养员和卡夫卡服务器正常启动，但这些消息要么不发送或接收。

C：\ Java2017 \ kafka_2.11-0.10.2.0 \ kafka_2.11-0.10.2.0 \ bin \ windows> kafka-console-producer --broker-list localhost：9092 --topic test testing .. 。

C：\ Java2017 \ kafka_2.11-0.10.2.0 \ kafka_2.11-0.10.2.0 \ bin \ windows> kafka-console-consumer --bootstrap-server localhost：9092 --topic test --from -beginning

Answer 1

你可能会做在实践中正确的事，但你上面指定的生产者命令应该是这样的：

C:\Java2017\kafka_2.11-0.10.2.0\kafka_2.11-0.10.2.0\bin\windows>kafka-console-producer --broker-list localhost:9092 --topic test 
>testing... 
>[Ctrl-C] 
C:\Java2017\kafka_2.11-0.10.2.0\kafka_2.11-0.10.2.0\bin\windows> 

如果像这样运行，将不会生成任何内容：

C:\Java2017\kafka_2.11-0.10.2.0\kafka_2.11-0.10.2.0\bin\windows>kafka-console-producer --broker-list localhost:9092 --topic test testing...