OrcHome OrcHome
OrcHome个人中心.

liang亮

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 liang亮 kafka中文教程 中:
那个我没用过,如果你看到消费者重新分配的日志,才会有消费重复。
另外,你的消费者客户端直接关闭,然后在启动,应该会拿到重复的信息吧?

1月前
liang亮 回复 半兽人 kafka中文教程 中:
30秒还是不行,我用的spring cloud stream kafka   代码很简单的  
1月前
liang亮 回复 半兽人 kafka中文教程 中:
问题专区在哪
1月前
半兽人 回复 liang亮 kafka中文教程 中:
你先等待30秒试试,另外你把代码发到问题专区里吧,我看看。
1月前
liang亮 回复 半兽人 kafka中文教程 中:
我已经设置了false
1月前
半兽人 回复 liang亮 kafka中文教程 中:
把自动提交关了。
1月前
liang亮 kafka中文教程 发表评论:
你好,我现在想模拟下重复消费的情况,session.timeout.ms 默认是10S  然后我在consumer 消费的时候加上了Thead.sleep(12S) 最后没有导致重复消费是什么情况 
1月前
半兽人 回复 liang亮 kafka中文教程 中:
http://www.orchome.com/5
你可能只有1个分区。
4月前
liang亮 回复 半兽人 kafka中文教程 中:
哦已经解决 ,但是现在这2consumer消费不均衡  有一个consumer一直收不到消息 全都跑到了另一个   当吧收到消息一端关闭时  这个收不到消息的consumer 才能接受到消息
4月前
半兽人 回复 liang亮 kafka中文教程 中:
group.id要相同。
4月前
liang亮 kafka中文教程 发表评论:
大神 请教一个问题  我现在开多个consumer去处理同一个主题里的消息 为什么我的多个consumer 都接收到了broker 发送过来的同一条消息
4月前

半兽人 回复 liang亮 kafka中文教程 评论:
那个我没用过,如果你看到消费者重新分配的日志,才会有消费重复。
另外,你的消费者客户端直接关闭,然后在启动,应该会拿到重复的信息吧?

1月前
liang亮 回复 半兽人 kafka中文教程 评论:
30秒还是不行,我用的spring cloud stream kafka   代码很简单的  
1月前
liang亮 回复 半兽人 kafka中文教程 评论:
问题专区在哪
1月前
半兽人 回复 liang亮 kafka中文教程 评论:
你先等待30秒试试,另外你把代码发到问题专区里吧,我看看。
1月前
liang亮 回复 半兽人 kafka中文教程 评论:
我已经设置了false
1月前
半兽人 回复 liang亮 kafka中文教程 评论:
把自动提交关了。
1月前
liang亮 kafka中文教程 发表评论:
你好,我现在想模拟下重复消费的情况,session.timeout.ms 默认是10S  然后我在consumer 消费的时候加上了Thead.sleep(12S) 最后没有导致重复消费是什么情况 
1月前
半兽人 回复 liang亮 kafka中文教程 评论:
http://www.orchome.com/5
你可能只有1个分区。
4月前
liang亮 回复 半兽人 kafka中文教程 评论:
哦已经解决 ,但是现在这2consumer消费不均衡  有一个consumer一直收不到消息 全都跑到了另一个   当吧收到消息一端关闭时  这个收不到消息的consumer 才能接受到消息
4月前
半兽人 回复 liang亮 kafka中文教程 评论:
group.id要相同。
4月前
liang亮 kafka中文教程 发表评论:
大神 请教一个问题  我现在开多个consumer去处理同一个主题里的消息 为什么我的多个consumer 都接收到了broker 发送过来的同一条消息
4月前