kafka git commit: KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink

Repository: kafka Updated Branches: refs/heads/0.10.1 2e0b9a70d -> abc47844b KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink Otherwise in this test the sink task goes through the pause/resume cycle with 0 assigned partitions, since the

kafka git commit: KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink

Repository: kafka Updated Branches: refs/heads/0.10.0 8814c2118 -> aa60a92c0 KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink Otherwise in this test the sink task goes through the pause/resume cycle with 0 assigned partitions, since the

kafka git commit: KAFKA-4569; Check for wakeup on every call to KafkaConsumer.poll

Repository: kafka Updated Branches: refs/heads/trunk 1abed91bd -> f3f9a9eaf KAFKA-4569; Check for wakeup on every call to KafkaConsumer.poll Author: Armin Braun Reviewers: Ismael Juma , Jason Gustafson Closes #2699 from original-brownbear/KAFKA-4569 Project: http://git-wip-us.apache.org/

kafka git commit: KAFKA-4881: add internal leave.group.on.close config to consumer

Repository: kafka Updated Branches: refs/heads/trunk d27e09e60 -> 1abed91bd KAFKA-4881: add internal leave.group.on.close config to consumer Author: Damian Guy Reviewers: Ismael Juma, Guozhang Wang Closes #2650 from dguy/consumer-leave-group-config Project: http://git-wip-us.apache.org/re

kafka git commit: MINOR: Use method handles instead of reflection for creating Snappy and LZ4 streams

Repository: kafka Updated Branches: refs/heads/trunk d348ac92c -> d27e09e60 MINOR: Use method handles instead of reflection for creating Snappy and LZ4 streams 1. Use Initialization-on-demand holder idiom that relies on JVM lazy-loading instead of explicit initialization check. 2. Method han