那个夏天像烤炉丶

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 那个夏天像烤炉丶kafka消费设置频率。 中 :

    消息一直保持接收,只是加上时间数量(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());
        }
    }
    
    3年前
  • 3年前