消息一直保持接收,只是加上时间
和数量(1条)
这2个条件,作为过滤条件。
while (true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
for (ConsumerRecord<String, String> record : records){
if(`时间`和`数量(1条)`){
// 你要做的业务
}
// 只打印,不做任务业务
System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
}
}