当我有一个Kafka控制台生产者的消息产生一些消息，然后启动一个消费者，我没有得到消息。不过，我收到的消息是在消费者启动后由生产者产生的。Kafka消费者应该在生产者之前启动吗？--从一开始，似乎给所有的信息，包括那些被消费。请在控制台级别和java客户机示例上帮助我先启动producer，然后通过启动consumer来消费。
nnsrf1az1#
Kafka存储消息的时间量是可配置的。默认为一周。消费者不需要“有空”来接收信息，但他们需要知道应该从哪里开始阅读控制台使用者具有查看所有分区的最新偏移量的默认选项。因此，如果你不积极地生产数据，你看不到什么作为一个消费者。您可以指定 group 控制台使用者或java客户机的标志，它跟踪在kafka协议中读取的偏移量，以及如果在组中停止该使用者，读取请求将从何处恢复否则，我认为您只能给出一个偏移量和一个分区
group
1条答案
按热度按时间nnsrf1az1#
Kafka存储消息的时间量是可配置的。默认为一周。消费者不需要“有空”来接收信息，但他们需要知道应该从哪里开始阅读
控制台使用者具有查看所有分区的最新偏移量的默认选项。因此，如果你不积极地生产数据，你看不到什么作为一个消费者。您可以指定
group控制台使用者或java客户机的标志，它跟踪在kafka协议中读取的偏移量，以及如果在组中停止该使用者，读取请求将从何处恢复否则，我认为您只能给出一个偏移量和一个分区