From 858c9b9576f00b7e6340aeae7cb9f0a228902463 Mon Sep 17 00:00:00 2001 From: asingh Date: Fri, 17 Jul 2015 22:01:40 -0700 Subject: [PATCH] KAFKA-2347: Add setConsumerRebalanceListener method to ZookeeperConsumerConnector java api --- core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java | 6 ++++++ 1 file changed, 6 insertions(+) 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 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(); -- 2.3.2 (Apple Git-55)