java - Receiving unstable offsets using Spring Cloud Kafka Binder - Stack Overflow

I have an application with multi-cluster binder that reads from one Kafka cluster and produces message

I have an application with multi-cluster binder that reads from one Kafka cluster and produces message to another Kafka cluster. At some point I started to receive such log messages:

1 --- [pool-2-thread-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-some-10, groupId=some] The following partitions still have unstable offsets which are not cleared on the broker side: [topicName-14], this could be either transactional offsets waiting for completion, or normal offsets waiting for replication after appending to local log

I have other applications that read from that cluster too and topic too, but no such error provided. I have no access to producer for that topic, so I do not know if even transactions are used there. The question is, is it problem with messages that producer wrote, or may my consumer be slow to commmit offsets? Or it is just a broker issue?

发布者:admin,转转请注明出处:http://www.yc00.com/questions/1744665962a4586751.html

相关推荐

发表回复

评论列表(0条)

  • 暂无评论

联系我们

400-800-8888

在线咨询: QQ交谈

邮件:admin@example.com

工作时间:周一至周五,9:30-18:30,节假日休息

关注微信