kafka git commit: KAFKA2805; RecordAccumulator request timeout not enforced when all brokers are gone

2015-11-11 Thread junrao
Repository: kafka Updated Branches: refs/heads/0.9.0 1828b8e52 -> 39ea9d3b7 KAFKA2805; RecordAccumulator request timeout not enforced when all brokers are gone Removed the check for expiring only those batches whose metadata is unavailable. Now the batches will be expired irrespective of

kafka git commit: KAFKA2805; RecordAccumulator request timeout not enforced when all brokers are gone

2015-11-11 Thread junrao
Repository: kafka Updated Branches: refs/heads/trunk 124f73b17 -> 1cd22ed33 KAFKA2805; RecordAccumulator request timeout not enforced when all brokers are gone Removed the check for expiring only those batches whose metadata is unavailable. Now the batches will be expired irrespective of