我尝试使用spring-boot应用程序连接到Kafka主题,但收到以下错误:
org.apache.kafka.common.errors.InconsistentGroupProtocolException: The group member's supported protocols are incompatible with those of existing members or first group member tried to join with empty protocol type or empty protocol list.
当我配置我的消费者时,我提供
security.protocol = SASL_SSL
ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
ssl.protocol = TLSv1.3
所以我不知道哪个协议缺失/为空。过去有人解决过这个问题吗?
我试着搜索这个站点,但是发现的问题并不适合我。例如,partition.assignment.strategy在服务器和我的spring Boot 应用程序中都是默认使用的。
1条答案
按热度按时间jbose2ul1#
此非信息性错误的原因是从Debezium发布消息的Kafka Connect组的名称与使用者的
group.id
相同。重命名使用者group.id
后,问题就解决了。