大佬请教两个问题:
一,consumer.poll 拉取kafka中消息(外层while(true))经常前几次拉不到数据,这是什么原因(kafka中一直有数据的),网络还是kafka机制的原因???
二,consumer.poll topic有三个分区,只有一个消费者,每次拉取时候,是随机从分片上拉取数据的,6中可能;这是什么原因呢, 打扰了,谢谢!!!
KafkaConsumer<String, String> kafkaConsumer = new KafkaConsumer<>(properties);
kafkaConsumer.subscribe(Collections.singletonList("activenodeStatus"));
while (true) {
ConsumerRecords<String, String> records = kafkaConsumer.poll(Duration.ofMillis(1));
}