java - Storm Trident のバッチ サイズ

Question

TRIDENT で BATCH SIZE (バッチに 10000 レコードを含める例) を設定する方法を知りたいです。コードに以下の構成があり、これにより、Kafka からバッチごとに約 250 レコードがフェッチされます。これを 10000*1024 に増やすことはできますか? または、バッチごとのレコード数を設定する方法があります。

TridentKafkaConfig tridentKafkaConfig = new TridentKafkaConfig(hosts, topic, consumerGroupId);
tridentKafkaConfig.scheme = new SchemeAsMultiScheme(new XScheme()); 
tridentKafkaConfig.fetchSizeBytes = 1024*1024;