kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: fix consumer config for streams
Date Tue, 23 Feb 2016 22:55:11 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 878b78acb -> f7fe9ccb4


HOTFIX: fix consumer config for streams

guozhangwang
My bad. I removed ZOOKEEPER_CONNECT_CONFIG from consumer's config by mistake. It is needed
by our own partition assigner running in consumers.

Author: Yasuhiro Matsuda <yasuhiro@confluent.io>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #959 from ymatsuda/hotfix3


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f7fe9ccb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f7fe9ccb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f7fe9ccb

Branch: refs/heads/trunk
Commit: f7fe9ccb466f85c417a545eb8acc4d61047c9f09
Parents: 878b78a
Author: Yasuhiro Matsuda <yasuhiro@confluent.io>
Authored: Tue Feb 23 14:55:07 2016 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Feb 23 14:55:07 2016 -0800

----------------------------------------------------------------------
 streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f7fe9ccb/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
index b835948..0cf2888 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -295,7 +295,6 @@ public class StreamsConfig extends AbstractConfig {
         props.remove(StreamsConfig.JOB_ID_CONFIG);
         props.remove(StreamsConfig.REPLICATION_FACTOR_CONFIG);
         props.remove(StreamsConfig.STATE_DIR_CONFIG);
-        props.remove(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG);
         props.remove(StreamsConfig.BUFFERED_RECORDS_PER_PARTITION_CONFIG);
         props.remove(StreamsConfig.NUM_STREAM_THREADS_CONFIG);
         props.remove(StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG);


Mime
View raw message