flink Auto-commit of offsets {test-1=OffsetAndMetadata{offset=49054662, metadata=''}} failed for group item_related_pre: Offset commit failed with a retriable exception
解决:
max.poll.interval.ms=300000 max.poll.records=500 默认,调节小一点
处理时间长,broker coordinator端认为consumer挂了
prop.setProperty("enable.auto.commit", "true")
prop.setProperty("max.poll.records","100")
prop.setProperty("auto.commit.interval.ms", "10000")
prop.setProperty("max.poll.interval.ms", "600000")
网友评论