ableegoldman opened a new pull request #11272: URL: https://github.com/apache/kafka/pull/11272
Most configs that are read and used by Streams today originate from the properties passed in to the KafkaStreams constructor, which means they get applied universally across all threads, tasks, subtopologies, and so on. The only current exception to this is the `topology.optimization` config which is parsed from the properties that get passed in to `StreamsBuilder#build`. However there are a handful of configs that could also be scoped to the topology level, allowing users to configure each NamedTopology independently of the others, where it makes sense to do so. This PR refactors the handling of these configs by interpreting the values passed in via KafkaStreams constructor as the global defaults, which can then be overridden for individual topologies via the properties passed in when building the NamedTopology. More topology-level configs may be added in the future, but this PR covers the following: 1. `max.task.idle.ms` 2. `task.timeout.ms` 3. `buffered.records.per.partition` 4. `default.timestamp.extractor.class` 5. `default.deserialization.exception.handler` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
