生产者一秒钟发送二十条生产信息,但是消费者这一块只想消费其中一条,其余的丢弃。请问这个应该怎么实现?
消息一直保持接收,只是加上时间和数量(1条)这2个条件,作为过滤条件。
时间
数量(1条)
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()); } }
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
消息一直保持接收,只是加上
时间
和数量(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()); } }
你的答案