0xffff-zhiyan opened a new pull request, #20242: URL: https://github.com/apache/kafka/pull/20242
There is a small logic bug in topic replay. If a topic is created and then removed before the TopicsDelta is applied, we end up with the deleted topic in createdTopics on the delta but not in deletedTopicIds. I think we are extremely unlikely to see this since MetadataLoader will apply the delta for each batch of records it receives. Since it’s impossible to see a TopicRecord and RemoveTopicRecord in the same batch, the only way this could surface is if MetadataLoader did some buffering. https://issues.apache.org/jira/browse/KAFKA-19497 Action: Remove the `topicName` from `createTopics` when replaying `RemoveTopicRecord` to make sure the topics that will be removed don't appear in `createTopics` -- 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
