野心永恒

0 声望

这家伙太懒,什么都没留下

个人动态

野心永恒 回复 半兽人 kafka消费者自动提交报错,kafka需要怎么配置呢? 中 :
每一次都new一个新的consumer是因为需要监听不同的topic,同一个consumer可以切换不同的topic吗?
2月前
半兽人 回复 野心永恒 kafka消费者自动提交报错,kafka需要怎么配置呢? 中 :
kafka消费者提交offset时,kafka集群正在重新分配消费者,就会报该错误。 kafka客户端自动是独立的线程,按间隔自动提交,当最后一次提交offset前,kafka消费者已经通知k8s关闭,释放了消费者的身份。 建议: 1. poll本身为长轮询,定时去拉取新消息,没必要每次new出来。 2. 改为手动提交
2月前
野心永恒 回复 半兽人 kafka消费者自动提交报错,kafka需要怎么配置呢? 中 :
调用了consumer.close();这个方法呢
2月前
半兽人 回复 野心永恒 kafka生产者客户端(0.10.1.1API) 中 :
你发送消息的时候用同步试试,估计你一开始就没成功过. .get()
3月前
半兽人 回复 野心永恒 异步发送消息到kafka失败 中 :
改掉我觉得就好了。 你试试。
3月前
3月前
关注了用户 半兽人 · 4月前

(゚∀゚ )
暂时没有任何数据