Repository: kafka
Updated Branches:
refs/heads/trunk 3b4c34794 -> a32962af1
HOTFIX: Remove failing ConnectDistributedTest.test_bad_connector_class
Since #1911 was merged it is hard to externally test a connector transitioning
to FAILED state due to an initialization failure, which is what thi
KAFKA-2066; Use client-side FetchRequest/FetchResponse on server
Author: Jason Gustafson
Reviewers: Jun Rao
Closes #2069 from hachikuji/KAFKA-2066
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3b4c3479
Tree: http://git-
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/main/java/org/apache/kafka/common/requests/RequestSend.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/requests/RequestSend.java
b/clients/
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
--
diff --git
a/clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderT
Repository: kafka
Updated Branches:
refs/heads/trunk 1f1d45006 -> 3b4c34794
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/core/src/main/scala/kafka/server/KafkaApis.scala
--
diff --git a/core/src/main/scala/kafka/s
http://git-wip-us.apache.org/repos/asf/kafka/blob/3b4c3479/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
--
diff --git
a/clients/src/main/java/org/apache/kafka/common/record/LogInputStream.java
b/client
Repository: kafka
Updated Branches:
refs/heads/trunk b7d36b726 -> 1f1d45006
KAFKA-4409; Fix deadlock between topic event handling and shutdown in
ZookeeperConsumerConnector
The consumer can deadlock on shutdown if a topic event fires during shutdown.
The shutdown acquires the rebalance lock
