卡夫卡消费者寻求开始

Question

我没有使用分区发布到 Kafka 主题。ProducerRecord(String topic, K key, V value)

在消费者方面，我想从头说起。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

Answer 1

生产时，如果您没有明确指定分区，生产者会自动从您的主题中选择一个。

在您的消费者中，如果您订阅了您的主题，您可以使用以下方式寻找您的消费者当前分配给的所有分区的开头：

consumer.seekToBeginning(consumer.assignment())