From b01d80d10548647e15f70c7fcaf34a0b8d8c5742 Mon Sep 17 00:00:00 2001 From: Yasuhiro Matsuda Date: Tue, 23 Feb 2016 14:47:55 -0800 Subject: [PATCH] HOTFIX: fix consumer config for streams --- .../src/main/java/org/apache/kafka/streams/StreamsConfig.java | 1 - 1 file changed, 1 deletion(-) 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 cf0684a7392de..1078b893f1075 100644 --- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java +++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java @@ -285,7 +285,6 @@ public Map getProducerConfigs(String clientId) { private void removeStreamsSpecificConfigs(Map props) { props.remove(StreamsConfig.JOB_ID_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);