Change max.poll.interval.ms to default (5 mins)
@@ -47,7 +47,6 @@ public class KafkaConnector {
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_INTERVAL_MS_CONFIG, "20000000");
// Gives more time to the consumer for processing the records so
// that the broker will NOT kill the consumer.
