Github user supermonk commented on the issue:
https://github.com/apache/storm/pull/1538
@harshach : Thanks for the update. I know that batch.size is useful in
Java Client for Latest Kafka Build, or do you think in the older version it
should hold good.
The storm 0.10 uses scala version and in trident (storm-kafka) I have not
seen anywhere the batch.size begin used. As per the below blog, there is no
specification done in the config.
**So I believe neither we are passing in the config, as per readme of
Storm-kafka nor we are doing the below calculation and pushing the config
internally.**
Kindly correct me if I am wrong!
https://gist.github.com/mrflip/5958028
spout_batch_kb ~= max_fetch_size * kafka_machines * kpartitions_per_broker
/ 1024
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
