张先森

0 声望

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

个人动态

张先森 kafka生产者客户端(0.10.1.1API) 发表评论:
我有个问题麻烦解答: 1.send()方法是异步的,返回一个Future。如果future调用get(),则将阻塞。这个意思是代表消息在到达kafka集群中的这段时间不会再发消息了,直到相关请求完成并返回该消息的metadata,或抛出发送异常。是这个意思吗?这样是不是可以 理解为是 一个同步发送的过程? 2.如果是callback()这个不会阻塞,相当于也是一个异步。但是消息到达集群后会回调方法。 不知道我上面理解的是否正确。看到后辛苦帮忙解答
8月前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中 :
组名要相同 就不会重复了。
1年前
张先森 回复 半兽人 kafka消费者客户端(0.10.0.1API) 中 :
谢谢解答。还有我为什么发送一个数据消费者能接受到三条相同的数据呢?这是为什么啊
1年前
半兽人 回复 张先森 kafka消费者客户端(0.10.0.1API) 中 :
是的,close相当于关闭了这个通道。
1年前

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