in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java [155:157]
public long getBatchSize() { return batchUpperLimit; }