Skip to content
Snippets Groups Projects
Commit 89770036 authored by guowei2's avatar guowei2 Committed by Tathagata Das
Browse files

[SPARK-8865] [STREAMING] FIX BUG: check key in kafka params

Author: guowei2 <guowei@growingio.com>

Closes #7254 from guowei2/spark-8865 and squashes the following commits:

48ca17a [guowei2] fix contains key
parent c9e2ef52
No related branches found
No related tags found
No related merge requests found
......@@ -410,7 +410,7 @@ object KafkaCluster {
}
Seq("zookeeper.connect", "group.id").foreach { s =>
if (!props.contains(s)) {
if (!props.containsKey(s)) {
props.setProperty(s, "")
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment