Размер партии в Storm Trident

Я хотел бы знать, как установить РАЗМЕР ПАКЕТА (например, я хочу, чтобы в пакете было 10000 записей) в TRIDENT. У меня есть приведенная ниже конфигурация в моем коде, и она извлекает примерно 250 записей за партию из Kafka. Могу ли я увеличить это до 10000*1024? или есть ли способ установить количество записей на партию.

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