[
https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421551#comment-16421551
]
ASF GitHub Bot commented on KAFKA-6657:
---------------------------------------
abbccdda opened a new pull request #4805: KAFKA-6657: Add StreamsConfig prefix
for different consumers
URL: https://github.com/apache/kafka/pull/4805
This pull request is for jira
[6657](https://issues.apache.org/jira/browse/KAFKA-6657). The KIP proposal is
[here](https://cwiki.apache.org/confluence/display/KAFKA/KIP-276+Add+StreamsConfig+prefix+for+different+consumers)
Added unit tests for new `getGlobalConsumerConfigs` API and make sure
existing restore consumer tests are passing.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Add StreamsConfig prefix for different consumers
> ------------------------------------------------
>
> Key: KAFKA-6657
> URL: https://issues.apache.org/jira/browse/KAFKA-6657
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 1.1.0
> Reporter: Matthias J. Sax
> Assignee: Boyang Chen
> Priority: Major
> Labels: beginner, needs-kip, newbie, newbie++
>
> Kafka Streams allows to pass in different configs for different clients by
> prefixing the corresponding parameter with `producer.` or `consumer.`.
> However, Kafka Streams internally uses multiple consumers, (1) the main
> consumer (2) the restore consumer and (3) the global consumer (that is a
> restore consumer as well atm).
> For some use cases, it's required to set different configs for different
> consumers. Thus, we should add two new prefix for restore and global
> consumer. We might also consider to extend `KafkaClientSupplier` and add a
> `getGlobalConsumer()` method.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
