张先森

0 声望

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

个人动态
  • 半兽人 回复 张先森 在 kafka生产者Java客户端 中 ：

    对的。

    5年前
  • 张先森 在 kafka生产者Java客户端 发表评论：

    我有个问题麻烦解答：
    1.send()方法是异步的，返回一个Future。如果future调用get()，则将阻塞。这个意思是代表消息在到达kafka集群中的这段时间不会再发消息了，直到相关请求完成并返回该消息的metadata，或抛出发送异常。是这个意思吗？这样是不是可以 理解为是 一个同步发送的过程？
    2.如果是callback（）这个不会阻塞，相当于也是一个异步。但是消息到达集群后会回调方法。
    不知道我上面理解的是否正确。看到后辛苦帮忙解答

    5年前
  • 半兽人 回复 张先森 在 kafka消费者Java客户端 中 ：

    组名要相同 就不会重复了。

    5年前
  • 张先森 回复 半兽人 在 kafka消费者Java客户端 中 ：

    谢谢解答。还有我为什么发送一个数据消费者能接受到三条相同的数据呢？这是为什么啊

    5年前
  • 半兽人 回复 张先森 在 kafka消费者Java客户端 中 ：

    是的,close相当于关闭了这个通道。

    5年前