Reduce batch size
Trying to minimise time to rebalance
@@ -46,7 +46,7 @@ public class KafkaConnector {
properties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, deserializer);
properties.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
properties.setProperty(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
- properties.setProperty(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "5");
+ properties.setProperty(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "1");
// Gives more time to the consumer for processing the records so
// that the broker will NOT kill the consumer.
