Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
We should make batchSize = max.poll.records at some point when we incorporate a build of Kafka that includes KIP-41 in both the Kafka channel and the Kafka sink
https://cwiki.apache.org/confluence/display/KAFKA/KIP-41%3A+KafkaConsumer+Max+Records