使用kafkalistener从kafka使用最少n条消息

db2dz4w8  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(362)

我需要消费Kafka与Kafka利斯泰纳一次最少n条消息
以下是消费者配置

Map<String, Object> props = new HashMap<>();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "batch");
    // maximum records per poll
    props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "10");
vxf3dgd4

vxf3dgd41#

使用spring-kafka无法保证消耗最少数量的消息。如果需要处理消息以执行有状态操作(聚合、还原…),请考虑使用kafka流,并保持kafka在可伸缩性、数据一致性方面提供的优势。。。

相关问题