首页 文章

Kafka 消费者寻求开始

提问于
浏览
1

我没有使用分区发布到Kafka主题 . ProducerRecord(String主题,K键,V值)

在消费者中,我想要开始 . seekToBeginning(集合分区)

是否可以在不使用分区的情况下寻求开始? Kafka是否分配了默认分区?

https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html

1 回答

  • 1

    生成时,如果您没有明确指定分区,则 生产环境 者将从您的主题中自动选择一个分区 .

    在您的消费者中,如果您订阅了您的主题,则可以使用以下内容来寻找消费者当前分配给的所有分区的开头:

    consumer.seekToBeginning(consumer.assignment())
    

相关问题