這個(gè)卡夫卡錯(cuò)誤是什么意思？[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 個(gè)分區(qū)有沒有匹配監(jiān)聽器的領(lǐng)導(dǎo)代理，包括 [topicname-0] (org.apache. kafka.clients.NetworkClient)我在跑步時(shí)得到它：./kafka-console-consumer.sh --topic topicname --bootstrap-server localhost:9094在嘗試閱讀本主題時(shí)，我在 golang 程序中遇到了一些錯(cuò)誤：2018/08/22 11:44:12 ReadOffsetWithRetryOnError conn 錯(cuò)誤：< 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)
}這很奇怪，因?yàn)樵陂喿x不同主題時(shí)它同時(shí)工作正常。更多錯(cuò)誤日志：/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topicname Topic:indexBlock PartitionCount:1ReplicationFactor:1 Configs: Topic: topicname 分區(qū): 0 Leader: -1 Replicas: 1002 Isr: 1002
6 回答
慕森王
TA貢獻(xiàn)1777條經(jīng)驗(yàn) 獲得超3個(gè)贊
[2018-08-22 11:40:49,429] WARN [Consumer clientId=consumer-1, groupId=console-consumer-62114] 1 個(gè)分區(qū)有沒有匹配監(jiān)聽器的領(lǐng)導(dǎo)代理，包括 [topicname-0] (org.apache. kafka.clients.NetworkClient)
如果您嘗試運(yùn)行多個(gè)消費(fèi)者并且 kafka 主題僅包含一個(gè)分區(qū)，也會(huì)發(fā)生此錯(cuò)誤。通常一個(gè)消費(fèi)者應(yīng)該映射一個(gè)分區(qū)。如果您使用兩個(gè)消費(fèi)者，那么您應(yīng)該在 kafka 主題中有 2 個(gè)分區(qū)。
尚方寶劍之說
TA貢獻(xiàn)1788條經(jīng)驗(yàn) 獲得超4個(gè)贊
就我而言，我在測(cè)試Kafka故障轉(zhuǎn)移時(shí)遇到了這個(gè)錯(cuò)誤。我放下了 1 Kafka，并希望將消息寫入另一個(gè) Kafka。
問題是主題replication-factor設(shè)置為 1，而我需要將其設(shè)置為 2。（2 個(gè) Kafka 實(shí)例）
獎(jiǎng)勵(lì)：
查看創(chuàng)建主題的目錄（在我的例子中是：kafka-logs-xx）Kafka，你就會(huì)明白為什么了:-)
莫回?zé)o
TA貢獻(xiàn)1865條經(jīng)驗(yàn) 獲得超7個(gè)贊
我想我的問題是我運(yùn)行了 2 個(gè)實(shí)例，沒有為復(fù)制設(shè)置任何特殊的東西。（可能沒有復(fù)制？）然后我刪除了一個(gè)代理。一些主題停止工作。
縹緲止盈
TA貢獻(xiàn)2041條經(jīng)驗(yàn) 獲得超4個(gè)贊
我在 docker 容器中運(yùn)行 Kafka 時(shí)遇到了這個(gè)問題。
以下解決方案有助于解決該問題。
@coldkreap正如這個(gè)答案的評(píng)論中提到的： https://stackoverflow.com/a/58067985/327862
kafka 代理信息在重新啟動(dòng)之間保留，因?yàn)?nbsp;
wurstmeister/kafka映像創(chuàng)建了一個(gè)名為“kafka”的卷。如果你運(yùn)行 docker volume ls 你會(huì)看到一個(gè) kafka 卷。刪除該卷，您將能夠重新創(chuàng)建主題等。
如果使用docker-compose，您可以運(yùn)行以下命令來刪除容器及其關(guān)聯(lián)的卷：
docker-compose down -v
或者
docker-compose rm -sv
拉莫斯之舞
TA貢獻(xiàn)1820條經(jīng)驗(yàn) 獲得超10個(gè)贊
jumping_monkey 在檢查目錄方面的獎(jiǎng)勵(lì)很有幫助。對(duì)我來說，我正在使用Bitnami Kafka進(jìn)行部署。在第一次部署時(shí)，我不在config掌舵值中。我想將保留時(shí)間更改為分鐘，并設(shè)置為：
config: |- log.retention.minutes=10
這導(dǎo)致log.dirs目錄從 切換/bitnami/kafka/data到/tmp/logs.
本質(zhì)上，數(shù)據(jù)存儲(chǔ)在 Kafka 代理上的位置導(dǎo)致了錯(cuò)誤的出現(xiàn)。
慕無忌1623718
TA貢獻(xiàn)1744條經(jīng)驗(yàn) 獲得超4個(gè)贊
就我而言，我在將我的 kafka 集群從 v2.0 更新到 v2.4 時(shí)遇到了這個(gè)錯(cuò)誤。原因是 server.properties 文件中 log.dirs 的配置設(shè)置錯(cuò)誤。因?yàn)槲覜]有注意到不同節(jié)點(diǎn)的不同磁盤名稱，而且我在 log.dirs 設(shè)置中不匹配磁盤名稱。
- 6 回答
- 0 關(guān)注
- 162 瀏覽
添加回答
舉報(bào)
0/150
提交
取消