我没有使用分区发布到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 回答
生成时,如果您没有明确指定分区,则 生产环境 者将从您的主题中自动选择一个分区 .
在您的消费者中,如果您订阅了您的主题,则可以使用以下内容来寻找消费者当前分配给的所有分区的开头: