Github user moesol commented on the issue:
https://github.com/apache/storm/pull/1287
Merged via different PR. Closing this PR.
---
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
Github user moesol closed the pull request at:
https://github.com/apache/storm/pull/1287
---
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
GitHub user moesol opened a pull request:
https://github.com/apache/storm/pull/1287
Addresses network flood from KafkaSpout to kafka server.
* Allows minBytes in fetch request to be configured
from KafkaConfig.fetchMinBytes.
* Defaults new configuration
Github user moesol commented on the pull request:
https://github.com/apache/storm/pull/1287#issuecomment-204239216
KafkaConfig has socketTimeoutMs which I assume maps to socket.timeout.ms.
It's passed along to the SimpleConsumer's constructor.
I'm not
Github user moesol commented on the pull request:
https://github.com/apache/storm/pull/1287#issuecomment-210955517
@knusbaum I added the JIRA ticket and updated the title a while ago. Are
you the person who will actually perform the merge?
---
If your project is set up for it, you
GitHub user moesol opened a pull request:
https://github.com/apache/storm/pull/1391
(STORM-1674) Idle KafkaSpout consumes more bandwidth than needed
* Allows minBytes in fetch request to be configured
from KafkaConfig.fetchMinBytes.
* Defaults new configuration
Github user moesol commented on the pull request:
https://github.com/apache/storm/pull/1391#issuecomment-21896
Without the MaxWait being set to 100, it is set to 1, which means that
the bolt will waiting for 10 seconds when no messages are available. On the 1.x
branch, I was
GitHub user moesol opened a pull request:
https://github.com/apache/storm/pull/1393
(STORM-1674) Idle KafkaSpout consumes more bandwidth than needed
* Allows minBytes in fetch request to be configured
from KafkaConfig.fetchMinBytes.
* Defaults new configuration
Github user moesol commented on the pull request:
https://github.com/apache/storm/pull/1393#issuecomment-220727660
I think it's awesome that this change is getting in! I'll be looking out
for the next release that contains this PR.
Robert Hastings, Lab SDL: 61
