Categories
Development

Consume minimum N number of messages once from Kafka with KafkaListener

I need to consumer minimum N number of messages once from Kafka with KafkaListener Below are the Consumer configurations 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”);

Categories
Development

I need to consumer minimum N number of messages once from Kafka with KafkaListener

Below are the Consumer configurations 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”);