Skip to content

Commit 9345442

Browse files
committed
KAFKA-2526: command line --producer-property wins
1 parent 3c4b1db commit 9345442

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

Diff for: core/src/main/scala/kafka/tools/ConsoleProducer.scala

+1-2
Original file line numberDiff line numberDiff line change
@@ -134,8 +134,6 @@ object ConsoleProducer extends Logging {
134134
Utils.loadProps(config.options.valueOf(config.producerConfigOpt))
135135
else new Properties
136136

137-
props ++= config.extraProducerProps
138-
139137
if (config.bootstrapServer != null)
140138
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, config.bootstrapServer)
141139
else
@@ -171,6 +169,7 @@ object ConsoleProducer extends Logging {
171169
CommandLineUtils.maybeMergeOptions(
172170
props, ProducerConfig.MAX_BLOCK_MS_CONFIG, config.options, config.maxBlockMsOpt)
173171

172+
props ++= config.extraProducerProps
174173
props
175174
}
176175

0 commit comments

Comments
 (0)