[jira] [Commented] (KAFKA-362) ZookeeperConsumerConnector needs to connect to new leader after leadership change

[ https://issues.apache.org/jira/browse/KAFKA-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13288640#comment-13288640 ] Jun Rao commented on KAFKA-362: --- In trunk, a partition only exists in 1 broker. So, once the

[jira] [Commented] (KAFKA-349) Create individual "Response" types for each kind of request and wrap them with "BoundedByteBufferSend", remove "xxResponseSend" types for all requests except "FetchReque

[ https://issues.apache.org/jira/browse/KAFKA-349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13288807#comment-13288807 ] Jun Rao commented on KAFKA-349: --- 75. ControllerToBrokerRequestTest should use TestUtils.creat

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (32 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-349 Create individual "Response" types for each kind of request and wrap them with "BoundedByteBufferSend", remove "xxResponseS