kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2347: Add setConsumerRebalanceListener method to ZookeeperConsumerConnector java api; reviewed by Jiangjie Qin, Ismael Juma, Grant Henke and Guozhang Wang
Date Tue, 28 Jul 2015 21:27:16 GMT
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 <asingh@cloudera.com>
Authored: Tue Jul 28 14:27:35 2015 -0700
Committer: Guozhang Wang <wangguoz@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();


Mime
View raw message