[
https://issues.apache.org/jira/browse/KAFKA-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roger Hoover updated KAFKA-4361:
--------------------------------
Description:
For the config params in CONSUMER_DEFAULT_OVERRIDES
(https://github.com/apache/kafka/blob/0.10.1/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java#L274)
such as consumer.max.poll.records and consumer.auto.offset.reset, those
parameters are not used and instead overridden by the defaults. It may not
work for some producer config values as well.
If your application sets those params in the StreamsConfig, they are not used
in the underlying Kafka Consumers (and possibly Producers)
was:
For the config params in CONSUMER_DEFAULT_OVERRIDES
(https://github.com/apache/kafka/blob/0.10.1/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java#L274)
such as consumer.max.poll.records and consumer.auto.offset.reset, those
parameters are not used and instead overridden by the defaults. It may not
work for some producer config values as well.
If your application sets those params in the StreamsConfig, they are not used
in the underlying Kafka Consumers
> Streams does not respect user configs for "default" params
> ----------------------------------------------------------
>
> Key: KAFKA-4361
> URL: https://issues.apache.org/jira/browse/KAFKA-4361
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 0.10.1.0
> Reporter: Roger Hoover
> Assignee: Damian Guy
>
> For the config params in CONSUMER_DEFAULT_OVERRIDES
> (https://github.com/apache/kafka/blob/0.10.1/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java#L274)
> such as consumer.max.poll.records and consumer.auto.offset.reset, those
> parameters are not used and instead overridden by the defaults. It may not
> work for some producer config values as well.
> If your application sets those params in the StreamsConfig, they are not used
> in the underlying Kafka Consumers (and possibly Producers)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
