1.背景

我写了一个程序，该程序是重建所有的kafka topic，步骤如下

删除kafka 调用shell
删除kafka的数据
删除zk上存储的信息

但是重建后，发现，消费者无法消费数据了，但是生成者仍然可以生成数据，并且在shell命令中，kafka-console-consumer.sh 是可以生产和消费的。

就算是写了一个最普通的消费者都无法正常的消费。日志有如下错误，或者没有错误。

Caused by: org.apache.kafka.common.errors.DisconnectException: null
2020

【Kafka】GroupCoordinatorNotAvailableException - The coordinator is not available相关推荐

【kafka】kafka 执行多个脚本 kafka-run-class.sh 导致 server 节点时不时挂掉
本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 文章目录 1.概述 2.规律 1.概述因为某些未知原因Flink任务总是挂掉,是跑了5-6个小时或者 ...
【kafka】Kafka 幂等 Producer
1.概述 [Kafka]Kafka幂等性原理及实现剖析 [kafka]Kafka 事务性之幂等性实现官网:Idempotent Producer 2.简介 Kafka提供了"至少一次&qu ...
【Kafka】Kafka 如果动态不停止的情况下修改消费组 offset
文章目录 1.概述 2.方案1 3.方案2 1.概述测试点:有人遇到这样的情况,他一个消费者正在消费一个环境的topic,然后他想启动另外一个消费组,但是是使用了同一个消费组,这个去更改消费组of ...
【kafka】kafka获取消费组异常 EOFException: null KeeperErrorCode
文章目录 1.场景1 1.1 概述 1.2 源码解析 1.2.1 sendRequest 1.2.2 receive 1.2.3 readCompletely 1.2 4 readFromReadab ...
【kafka】kafka kerberos Cannot locate KDC Unable to locate KDC for realm
文章目录 1.概述 2.场景2 1.概述本次是在 [kafka]kafka 消费带有 kerberos认证的服务器这个都搞通的情况下,搞这个. 机器的环境如下 12.12.12.24 kdc服务 ...
【kafka】kafka kerberos KeeperErrorCode = InvalidACL for /config/topics
文章目录 1.概述 1.概述环境搭建参考:[kafka]kafka 消费带有 kerberos认证的服务器在这个kerberos认证的环境下,我想测试一下,构建zk的客户端是否需要认证,然后代码 ...
【kafka】Replication factor: 1 larger than available brokers:0
文章目录 1.概述 1.概述文章重复了:[Kafka]kafka replication factor : 3 larger than avaiable brokers:2 kafka现在一创建消费 ...
【kafka】kerberos Server not found in Kerberos database LOOKING_UP_SERVER Identifier doesn‘t match
文章目录 1.概述 2.配置如下 3.测试 1.概述首先参考kafka的配置环境:[kafka]kerberos认证下 kafka 报错Bootstrap broker host:ip (id: - ...
【kafka】kerberos client is being asked for a password not available to garner authentication informa
文章目录 1.场景1 1.1 概述 1.2.具体测试 2.场景2 3.1 概述 3.2 解决 1.场景1 关联文章: [zookeeper]zookeeper的ACL权限控制 1.1 概述首先参考k ...

【Kafka】GroupCoordinatorNotAvailableException - The coordinator is not available

1.背景

【Kafka】GroupCoordinatorNotAvailableException - The coordinator is not available相关推荐

最新文章

热门文章