Hi, I believe the constants used by KafkaConfig in the old external storm-kafka are incorrectly set to.
fetchMaxWait = FetchRequest.DefaultMaxWait(); minFetchByte = FetchRequest.DefaultMinBytes(); And these are not the values intended 1,100, but 0,0. I believe the intended values are actually fetchMaxWait = ConsumerConfig.MaxFetchWaitMs(); minFetchByte = ConsumerConfig.MinFetchBytes(); This effects, 1.0.x, 1.1.x, 1.2.x, and is slightly different, but still effects 2.x As far as I can tell, this has never been correct, since the original merge of 1674. It's easy to check by just making a KafkaConfig, or SpoutConfig and reading the values. Sorry, don't have time to contribute a patch. Best regards, *Peter Chamberlain* | Senior Software Engineer | HTK Telephone: +44(0)870 600 2311 Connect with me: *Email* <[email protected]> [image: htk logo] <http://www.htk.co.uk/> Connect with HTK: *htk.co.uk* <http://www.htk.co.uk/> | *Linked in* <http://www.linkedin.co.uk/company/htk> | *Twitter* <http://www.twitter.com/htkhorizon> HTK Limited, Chapmans Warehouse, Wherry Quay, Ipswich, IP4 1AS, UK. Company Registered in England and Wales as 3191677, VAT Number 675 9467 71 PLEASE CONSIDER THE ENVIRONMENT BEFORE PRINTING THIS EMAIL.
