Vahid Hashemian created KAFKA-3982:
--------------------------------------
Summary: Issue with processing order of consumer properties in
console consumer
Key: KAFKA-3982
URL: https://issues.apache.org/jira/browse/KAFKA-3982
Project: Kafka
Issue Type: Bug
Components: consumer
Reporter: Vahid Hashemian
Assignee: Vahid Hashemian
Priority: Minor
With the recent introduction of {{consumer.property}} argument in console
consumer, both new and old consumer could overwrite certain properties provided
using this new argument.
Specifically, the old consumer would overwrite the values provided for
[{{auto.offset.reset}}|https://github.com/apache/kafka/blob/10bbffd75439e10fe9db6cf0aa48a7da7e386ef3/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L173]
and
[{{zookeeper.connect}}|https://github.com/apache/kafka/blob/10bbffd75439e10fe9db6cf0aa48a7da7e386ef3/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L174],
and the new consumer would overwrite the values provided for
[{{auto.offset.reset}}|https://github.com/apache/kafka/blob/10bbffd75439e10fe9db6cf0aa48a7da7e386ef3/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L196],
[{{key.deserializer}}|https://github.com/apache/kafka/blob/10bbffd75439e10fe9db6cf0aa48a7da7e386ef3/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L198],
and
[{{key.deserializer}}|https://github.com/apache/kafka/blob/10bbffd75439e10fe9db6cf0aa48a7da7e386ef3/core/src/main/scala/kafka/tools/ConsoleConsumer.scala#L199].
This seems to be because the properties provided via {{consumer.property}}
argument are not considered when finalizing the configuration of the consumer.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
