kafka异常汇总

1.o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-3, groupId=YYY] Offset commit failed on partition XXX-45 at offset 13898997: The coordinator is not aware of this member.

2. failed: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.

3.java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access

4.

[kafka-producer-network-thread | producer-1] o.s.k.support.LoggingProducerListener    : Exception thrown when sending a message with key='null' and payload='{YYYY...' to topic XXX:

org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for XXXtopic-3: 38877 ms has passed since batch creation plus linger time

最后

以上就是动人含羞草为你收集整理的kafka异常汇总的全部内容，希望文章能够帮你解决kafka异常汇总所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。