出現該錯,不用修改任何配置檔案,原因為: 目前使用的 建立消費者指令 與 安裝的kafka版本不一緻,因為kafka在0.9版本之後,使用建立的kafka 消費者指令已經變了。
例如,我安裝的是kafka 2.1.1版本, 建立消費者consumer 應該如下:
進入kafka安裝目錄, 運作指令:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testJc --from-beginning
如:

或者進入到windows目錄:
.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testJc
PS : 建立主題:
進入kafka安裝目錄, 運作指令:
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic testJc
如:
或者進入到windows目錄下:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test098
建立生産者 producer:
進入kafka安裝目錄, 運作指令:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testJc
如: