Increases the MAX_POLL_INTERVAL to process large call graphs and prevent Kafka from destroying the OPAL consumer.
@@ -46,8 +46,8 @@ public abstract class FastenKafkaConnection extends Thread {
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, "10");
- properties.setProperty(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "1000000");
+ 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.
properties.setProperty(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, "200000");
