加载中
kafka max.poll.records用法介绍

一、max.poll.records是什么 max.poll.records是Kafka consumer的一个配置参数,表示consumer一次从Kafka broker中拉取的最大消息数目。默认值为500条。 在Kafka中,一个consumer group可以有...

使用Kafka时一定要注意防止消费速度过慢触发rebalance而导致的重复消费

在Java应用中,我们往往会使用spring-kafka组件简单的设置一下group_id, topic就开始消费消息了,其实这样会埋下巨大的安全隐患,即当消费速度过慢时有可能会触发rebalance, 这批消息被分配到...

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部