Commit fd75354c authored by Álex Cortiñas's avatar Álex Cortiñas

Reducing maxPoll to half its value

parent 9ac7062b
......@@ -15,7 +15,7 @@ import org.slf4j.LoggerFactory;
public class KafkaReader {
private static final Logger logger = LoggerFactory.getLogger(KafkaReader.class);
private static final int maxPoll = 10000;
private static final int maxPoll = 5000;
private static final int intervalCommit = 60000;
private static Properties props = null;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment