這個卡夫卡錯誤是什么意思？[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 個分區有沒有匹配監聽器的領導代理，包括 [topicname-0] (org.apache. kafka.clients.NetworkClient)我在跑步時得到它：./kafka-console-consumer.sh --topic topicname --bootstrap-server localhost:9094在嘗試閱讀本主題時，我在 golang 程序中遇到了一些錯誤：2018/08/22 11:44:12 ReadOffsetWithRetryOnError conn 錯誤：< dial tcp :0: connect: connection refused > kafka0:9094 topic: 0代碼片段：conn, err := kafka.DialLeader(context.Background(), "tcp", ip, getTopic(topic), 0)
if err != nil {
log.Println("ReadOffsetWithRetryOnError conn error: <", err, "> ", ip, " topic:", topic)
}這很奇怪，因為在閱讀不同主題時它同時工作正常。更多錯誤日志：/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topicname Topic:indexBlock PartitionCount:1ReplicationFactor:1 Configs: Topic: topicname 分區: 0 Leader: -1 Replicas: 1002 Isr: 1002
6 回答
慕森王
TA貢獻1777條經驗 獲得超3個贊
[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 個分區有沒有匹配監聽器的領導代理，包括 [topicname-0] (org.apache. kafka.clients.NetworkClient)
如果您嘗試運行多個消費者并且 kafka 主題僅包含一個分區，也會發生此錯誤。通常一個消費者應該映射一個分區。如果您使用兩個消費者，那么您應該在 kafka 主題中有 2 個分區。
尚方寶劍之說
TA貢獻1788條經驗 獲得超4個贊
就我而言，我在測試Kafka故障轉移時遇到了這個錯誤。我放下了 1 Kafka，并希望將消息寫入另一個 Kafka。
問題是主題replication-factor設置為 1，而我需要將其設置為 2。（2 個 Kafka 實例）
獎勵：
查看創建主題的目錄（在我的例子中是：kafka-logs-xx）Kafka，你就會明白為什么了:-)
縹緲止盈
TA貢獻2041條經驗 獲得超4個贊
我在 docker 容器中運行 Kafka 時遇到了這個問題。
以下解決方案有助于解決該問題。
@coldkreap正如這個答案的評論中提到的： https://stackoverflow.com/a/58067985/327862
kafka 代理信息在重新啟動之間保留，因為
wurstmeister/kafka映像創建了一個名為“kafka”的卷。如果你運行 docker volume ls 你會看到一個 kafka 卷。刪除該卷，您將能夠重新創建主題等。
如果使用docker-compose，您可以運行以下命令來刪除容器及其關聯的卷：
docker-compose down -v
或者
docker-compose rm -sv
拉莫斯之舞
TA貢獻1820條經驗 獲得超10個贊
jumping_monkey 在檢查目錄方面的獎勵很有幫助。對我來說，我正在使用Bitnami Kafka進行部署。在第一次部署時，我不在config掌舵值中。我想將保留時間更改為分鐘，并設置為：
config: |- log.retention.minutes=10
這導致log.dirs目錄從 切換/bitnami/kafka/data到/tmp/logs.
本質上，數據存儲在 Kafka 代理上的位置導致了錯誤的出現。
慕無忌1623718
TA貢獻1744條經驗 獲得超4個贊
就我而言，我在將我的 kafka 集群從 v2.0 更新到 v2.4 時遇到了這個錯誤。原因是 server.properties 文件中 log.dirs 的配置設置錯誤。因為我沒有注意到不同節點的不同磁盤名稱，而且我在 log.dirs 設置中不匹配磁盤名稱。
- 6 回答
- 0 關注
- 154 瀏覽
添加回答
舉報
0/150
提交
取消