apache - Kafka 偏移量提交在偏移量 29 处的分区 test3-0 上失败:这不是正确的协调器
问题描述
当我测试Kafka时,发生了错误。没看懂什么意思,有三台服务器,我关闭了另外两台没有任何问题,但是当我关闭另一台时,就会出现这个错误
[2018-08-30 08:51:48,824] WARN [Consumer clientId=consumer-1, groupId=console-consumer-51176] Connection to node 2147483646 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-08-30 08:51:49,044] WARN [Consumer clientId=consumer-1, groupId=console-consumer-51176] Connection to node 2147483646 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-08-30 08:51:49,151] WARN [Consumer clientId=consumer-1, groupId=console-consumer-51176] Connection to node 1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-08-30 08:52:14,004] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-51176] Offset commit failed on partition test3-0 at offset 29: This is not the correct coordinator. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2018-08-30 08:52:14,115] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-51176] Offset commit failed on partition test3-0 at offset 29: This is not the correct coordinator. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2018-08-30 08:52:14,224] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-51176] Offset commit failed on partition test3-0 at offset 29: The coordinator is loading and hence can't process requests. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
解决方案
推荐阅读
- c# - 在 wpf webbrowser 窗口而不是下载对话框中获取 json 内容
- excel-2010 - 如果和条件
- c++ - 如何将 cin 用于数组
- postgresql - Postgres - 使用 SELECT 和 ON COMMIT DROP 创建临时表
- javascript - 动态渲染 ember 组件
- php - PHP如何从多维数组中删除键?
- python - 立即在 QMainWindow __init__() 上发出请求
- git - vim打开多个文件
- ansible - 在路径中使用 bash 命令进行 Ansible 复制
- java - “未指定 jdk”,同时尝试在物理设备上安装 apk