kafka消费设置频率。

那个夏天像烤炉丶 发表于: 2021-09-06 最后更新时间: 2021-09-06 17:09:40 2,053 游览

生产者一秒钟发送二十条生产信息，但是消费者这一块只想消费其中一条，其余的丢弃。请问这个应该怎么实现？

kafka

发表于 2021-09-06

那个夏天像烤炉丶

消息一直保持接收，只是加上时间和数量（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());
    }
}