You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/07/28 23:27:16 UTC
kafka git commit: KAFKA-2347: Add setConsumerRebalanceListener method
to ZookeeperConsumerConnector java api;
reviewed by Jiangjie Qin, Ismael Juma, Grant Henke and Guozhang Wang
Repository: kafka
Updated Branches:
refs/heads/trunk 269c2407d -> 3df46bf4c
KAFKA-2347: Add setConsumerRebalanceListener method to ZookeeperConsumerConnector java api; reviewed by Jiangjie Qin, Ismael Juma, Grant Henke and Guozhang Wang
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/3df46bf4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/3df46bf4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/3df46bf4
Branch: refs/heads/trunk
Commit: 3df46bf4ce9c134cc7b532be3d01f920127be706
Parents: 269c240
Author: Ashish Singh <as...@cloudera.com>
Authored: Tue Jul 28 14:27:35 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Jul 28 14:27:35 2015 -0700
----------------------------------------------------------------------
.../main/scala/kafka/javaapi/consumer/ConsumerConnector.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/3df46bf4/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
index ca74ca8..444cd1d 100644
--- a/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
+++ b/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
@@ -76,6 +76,12 @@ public interface ConsumerConnector {
public void commitOffsets(Map<TopicAndPartition, OffsetAndMetadata> offsetsToCommit, boolean retryOnFailure);
/**
+ * Wire in a consumer rebalance listener to be executed when consumer rebalance occurs.
+ * @param listener The consumer rebalance listener to wire in
+ */
+ public void setConsumerRebalanceListener(ConsumerRebalanceListener listener);
+
+ /**
* Shut down the connector
*/
public void shutdown();