在执行以下代码之后,echange将只有一条来自kafka的消息。默认值为maxPollRecords为500。Exchange exchange = kafkaConsumer.receive(kafkaEndpoint, 100);//ConsumerTemplate kafkaConsumer;ConsumerRecords<String, String> records = co
当消费者组A的Kafka使用者连接到Kafka broker时,我想寻求到所有分区的末尾,即使在代理端存储了偏移量。如果更多的消费者正在为同一消费者组连接,他们应该收集最新存储的偏移量。我所做的工作如下:consumer.seekToEnd(emptyList())
val records = consumer.pollif(records.isNotEmpty()) {
我试图使用卡夫卡消费对象从错误的/不存在的主题名中消费。下面是我在投票线之后的日志。WARN 19508 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : Error while fetching metadataconsumer.subscribe(Arrays.asList(topic)); records = c