旧象

0 声望

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

个人动态
  • 半兽人 回复 旧象 在 Kafka客户端consumer无法消费到消息 中 ：

    长轮询拉取消息，poll(500)，当没有消息时，阻塞在这里了。
    根据消费者group，同一个group中，消息只会被其中一个消费者消费。不同的消费者组，均能收到消息。

    7年前
  • 旧象 在 Kafka客户端consumer无法消费到消息 发表评论：

    我后面尝试了一下，先开启kafka消费者客户端，然后开启kafka生产者客户端，产生新的消息，发现这时的消费者客户端可以消费到新的消息，这里有点懵了。难道是偏移量的问题？前面没有消费到消息的情况是：我先打开Linux上的消费者，然后从windows上的生产者客户端生产消息到kafka集群，然后Linux上的消费者消费到了消息，然后再启动windows上的消费者客户端就消费不到消息了。请问是不是消息只能处理一次？consumer客户端如何控制从哪里开始消费消息呢？

    7年前
  • 发表了 Kafka客户端consumer无法消费到消息  
    7年前