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 2016/02/23 23:55:11 UTC
kafka git commit: HOTFIX: fix consumer config for streams
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 <ya...@confluent.io>
Reviewers: Guozhang Wang <wa...@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 <ya...@confluent.io>
Authored: Tue Feb 23 14:55:07 2016 -0800
Committer: Guozhang Wang <wa...@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);