kafka報錯
17/04/06 09:47:15 ERROR admin.TopicCommand$: kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0
很有可能是你broker沒起來,還有一個原因是你你zookeeper配置目錄不對,
kafka-topics --create --zookeeper master02:2181,master01:2181,slave01:2181,slave02:2181,slave03:2181/kafka --replication-factor 1 --partitions 1 --topic TEST-TOPIC
我的是/kafka,你可以到zookeeper上去看你的目錄,這是coudera做的改變。
2.error reconnect due to
在cloudera叢集的kafka的時候本地要配上hadoop_home才可以連線kafka,所以我配置了cdh的hadoop_home.
問題:
A broker is already registered on the path /brokers/ids/0.
解決
配置檔案裡存在broker.id重複,檢查一下每一臺的broker.id是否與其他機器的broker.id不一樣
問題
Exception in thread "main" java.lang.UnsupportedClassVersionError: kafka/Kafka : Unsupported major.minor version 51.0
解決
jdk版本不對,我用的kafka版本:2.10-0.10.1.0 對應jdk版本:1.7 不能用1.6
問題
ERROR Processor got uncaught exception. (kafka.network.Processor)
java.nio.BufferUnderflowException
解決
客戶端的jar包和叢集的版本號在小版本不一致,注意客戶端的jar包不只要大版本一致,還要小版本完全一致,不一致的時候報的錯不只這個.