你好,用你的框架,重新配置了kafka消费者,结果报如下错误:
org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is 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.
将消费组id换一个新的,就解决了,但是项目中要求不能换新的消费者id,能麻烦提供一个解决方案吗?配置如下所示:

你好,用你的框架,重新配置了kafka消费者,结果报如下错误:
org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is 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.
将消费组id换一个新的,就解决了,但是项目中要求不能换新的消费者id,能麻烦提供一个解决方案吗?配置如下所示:
