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