[KAFKA-8813] Race condition when creating topics and changing their configuration

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.4.0
• Assignee: Vikas Singh
• Reporter: Gwen Shapira
• Created: 19/Aug/19 01:16
• Updated: 15/Oct/19 18:30
• Resolved: 15/Oct/19 18:24

Description

In Partition.createLog we do:

val props = stateStore.fetchTopicConfig()
val config = LogConfig.fromProps(logManager.currentDefaultConfig.originals, props)
val log = logManager.getOrCreateLog(topicPartition, config, isNew, isFutureReplica)

https://github.com/apache/kafka/blob/33d06082117d971cdcddd4f01392006b543f3c01/core/src/main/scala/kafka/cluster/Partition.scala#L314-L316

Config changes that arrive after configs are loaded from ZK, but before LogManager added the partition to `futureLogs` or `currentLogs` where the dynamic config handlers picks up topics to update their configs, will be lost.

Issue Links

• links to: GitHub Pull Request #7305