我需要消费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");
1条答案
按热度按时间vxf3dgd41#
使用spring-kafka无法保证消耗最少数量的消息。如果需要处理消息以执行有状态操作(聚合、还原…),请考虑使用kafka流,并保持kafka在可伸缩性、数据一致性方面提供的优势。。。