1. 程式人生 > >kafka報錯

kafka報錯

1.Error while executing topic command : replication factor: 1 larger than available brokers: 0

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包不只要大版本一致,還要小版本完全一致,不一致的時候報的錯不只這個.