kafka git commit: MINOR: remove ignore annotations in Streams EOS integration test

2017-06-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.11.0 0c9e4af11 -> 3d0f0caf7 MINOR: remove ignore annotations in Streams EOS integration test Author: Guozhang Wang Reviewers: Jason Gustafson , Apurva Mehta Closes #3251 from

kafka git commit: MINOR: remove ignore annotations in Streams EOS integration test

2017-06-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 202cb8ea8 -> b01c83ea9 MINOR: remove ignore annotations in Streams EOS integration test Author: Guozhang Wang Reviewers: Jason Gustafson , Apurva Mehta Closes #3251 from

kafka git commit: KAFKA-5366; Add concurrent reads to transactions system test

2017-06-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk d655d806e -> 202cb8ea8 KAFKA-5366; Add concurrent reads to transactions system test This currently fails in multiple ways. One of which is most likely KAFKA-5355, where the concurrent consumer reads duplicates. During broker bounces, the

kafka git commit: KAFKA-5366; Add concurrent reads to transactions system test

2017-06-06 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.11.0 547ddcb1b -> 0c9e4af11 KAFKA-5366; Add concurrent reads to transactions system test This currently fails in multiple ways. One of which is most likely KAFKA-5355, where the concurrent consumer reads duplicates. During broker bounces, the

kafka git commit: KAFKA-4942: Fix commitTimeoutMs being set before the commit actually started

2017-06-06 Thread ewencp
Repository: kafka Updated Branches: refs/heads/trunk 2244c68eb -> d655d806e KAFKA-4942: Fix commitTimeoutMs being set before the commit actually started This fixes KAFKA-4942 This supersededs #2730 /cc simplesteph gwenshap ewencp Author: Nick Pillitteri

kafka git commit: MINOR: expose commit interval config for SimpleBenchmark

2017-06-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk ad8e7cf5e -> 2244c68eb MINOR: expose commit interval config for SimpleBenchmark Expose the streams commit interval config for different testing scenarios. Author: Bill Bejeck Reviewers: Guozhang Wang

kafka git commit: MINOR: update stream docs for kip-134

2017-06-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.11.0 c39fea37e -> 503f92721 MINOR: update stream docs for kip-134 Add a section in the streams docs about the broker config introduced in KIP-134 Author: Damian Guy Reviewers: Michael G. Noll, Bill Bejeck, Guozhang Wang

kafka git commit: MINOR: update stream docs for kip-134

2017-06-06 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 3de683993 -> ad8e7cf5e MINOR: update stream docs for kip-134 Add a section in the streams docs about the broker config introduced in KIP-134 Author: Damian Guy Reviewers: Michael G. Noll, Bill Bejeck, Guozhang Wang

kafka git commit: KAFKA-4948; Wait for offset commit in test to fix transient failure

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk cb78ba129 -> 3de683993 KAFKA-4948; Wait for offset commit in test to fix transient failure `DescribeConsumerGroupTest#testDescribeExistingGroupWithNoMembersWithNewConsumer` shuts down the consumer executor thread and then checks that the

kafka git commit: KAFKA-4948; Wait for offset commit in test to fix transient failure

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 9419204c2 -> c39fea37e KAFKA-4948; Wait for offset commit in test to fix transient failure `DescribeConsumerGroupTest#testDescribeExistingGroupWithNoMembersWithNewConsumer` shuts down the consumer executor thread and then checks that the

kafka git commit: KAFKA-5364; ensurePartitionAdded does not handle pending partitions in abortable error state [Forced Update!]

2017-06-06 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 1c59aa735 -> 9419204c2 (forced update) KAFKA-5364; ensurePartitionAdded does not handle pending partitions in abortable error state Author: Jason Gustafson Reviewers: Apurva Mehta , Guozhang Wang

kafka git commit: KAFKA-5364; ensurePartitionAdded does not handle pending partitions in abortable error state [Forced Update!]

2017-06-06 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 3eed19458 -> cb78ba129 (forced update) KAFKA-5364; ensurePartitionAdded does not handle pending partitions in abortable error state Author: Jason Gustafson Reviewers: Apurva Mehta , Guozhang Wang

kafka git commit: KAFKA-5364; ensurePartitionAdded does not handle pending partitions in abortable error state

2017-06-06 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 313f8d7dd -> 3eed19458 KAFKA-5364; ensurePartitionAdded does not handle pending partitions in abortable error state Author: Jason Gustafson Reviewers: Apurva Mehta , Guozhang Wang

kafka git commit: MINOR: Create offsets topic explicitly in DescribeConsumerGroupTest

2017-06-06 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 1d943a765 -> b9c876ee0 MINOR: Create offsets topic explicitly in DescribeConsumerGroupTest This should fix transient failures due to timeouts caused by slow auto creation of the offsets topic. The one exception is

kafka git commit: MINOR: Create offsets topic explicitly in DescribeConsumerGroupTest

2017-06-06 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 17b2bde4b -> 313f8d7dd MINOR: Create offsets topic explicitly in DescribeConsumerGroupTest This should fix transient failures due to timeouts caused by slow auto creation of the offsets topic. The one exception is

kafka git commit: KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 8f9ee0ee4 -> 1d943a765 KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #2835 from

kafka git commit: KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS

2017-06-06 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 4b37918ef -> 17b2bde4b KAFKA-5051; Avoid reverse DNS lookup to obtain hostname for TLS Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #2835 from