Kafka遇到报错：The group member‘s supported protocols are incompatible with those of existing members

报错信息

InconsistentGroupProtocolException：The group member's supported protocols are incompatible with those of existing members

为何报错

在使用docker安装kafka-connect插件的时候，运行下面的docker指令：

docker run -d --name connect -p 8083:8083
-e GROUP_ID=1
-e CONFIG_STORAGE_TOPIC=connect-configs
-e OFFSET_STORAGE_TOPIC=connect-offsets
-e STATUS_STORAGE_TOPIC=connect-status
--link zookeeper:zookeeper
--link kafka:kafka
quay.io/debezium/connect

出现上面的协议不适用的报错。

参考解决方案

通过查找相关资料，初步可以认定出现这个问题是group_id出现重复。
下面的两个回答作为参考：
https://stackoverflow.com/questions/41601771/kafkastreams-inconsistentgroupprotocolexception
https://github.com/micronaut-projects/micronaut-kafka/issues/31
有一个Kafka相关的Jira也与该报错相关：
https://issues.apache.org/jira/browse/KAFKA-3829

最终解决

通过修改group_id值，避免重复，得以规避该类问题。

docker run -d --name connect -p 8083:8083
-e GROUP_ID=10
-e CONFIG_STORAGE_TOPIC=connect-configs
-e OFFSET_STORAGE_TOPIC=connect-offsets
-e STATUS_STORAGE_TOPIC=connect-status
--link zookeeper:zookeeper
--link kafka:kafka
quay.io/debezium/connect

对该问题理解不够深刻，大概定位原因在于group_id的重复导致的，欢迎指正。

Kafka遇到报错：The group member‘s supported protocols are incompatible with those of existing members相关推荐

The group member's supported protocols are incompatible with those of existing members
启动kafka消费者报错: Exception in thread "Thread-2" org.apache.kafka.common.errors.InconsistentGr ...
【kafka】InconsistentGroupProtocolException: The group member‘s supported protocols
1.场景1 1.1 概述 org.apache.kafka.common.errors.InconsistentGroupProtocolException: The group member's s ...
kafka启动报错Java HotSpotTM 64-bit Server VM warning:INFO: os::commit_memory
版权声明:版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/qq_39501726/article/details/81938695 kafka启动报错 ...
kafka tool报错:Error fetching datea.Offset out of range
kafka tool报错 Error fetching datea.Offset out of range 解决方案: Kafka tool 升级最新2.0版本,没有此错误转载于:https://w ...
【kafka】kafka消费者报错INVALID_FETCH_SESSION_EPOCH
1.概述 kafka消息积压会导致cpu飙升吗我从kafka中批量拿日志遍历然后json反序列化成对象在将对象批量入库在某次入库之后日志打印INVALID_FETCH_SESSION_EPOC ...
【kafka】kafka 启动报错 InvalidReceiveException: Invalid receive (size = -720899)
1.概述 kafka启动报错InvalidReceiveException: Invalid receive (size = -720899) 参考文章:https://bbs.csdn.net/to ...
Kafka 启动报错 AccessDeniedException
Kafka 启动报错 AccessDeniedException 今天在本地电脑window环境上下载kafka,启动zookeeper正常,启动kafka时报:java.nio.file.Acces ...
xcode opencv报错：no member named “xxx” in the global namespace
mac系统安装opencv后,xcode中工程报错:no member named "xxx" in the global namespace 解决方法: 参考文章:https:/ ...
pip 安装报错，is not a supported wheel on this platform
可能的原因1:安装的不是对应python版本的库,下载的库名中cp27代表python2.7,其它同理. 可能的原因2:这个是我遇到的情况(下载的是对应版本的库,然后仍然提示不支持当前平台) 我下载到 ...