kafka消费设置频率。

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

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

发表于 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());
    }
}
你的答案

查看kafka相关的其他问题或提一个您自己的问题