KAFKA-12257; Consumer mishandles topics deleted and recreated with the same name (#10952)
Store topic ID info in consumer metadata. We will always take the topic ID from the latest metadata response and remove any topic IDs from the cache if the metadata response did not return a topic ID for the topic. The benefit of this is that it lets us detect topic recreations. This allows the client to update metadata even if the leader epoch is lower than what was seen previously. Reviewers: Luke Chen <showuon@gmail.com>, Jason Gustafson <jason@confluent.io>
显示
- clients/src/main/java/org/apache/kafka/clients/Metadata.java 40 个添加, 13 个删除clients/src/main/java/org/apache/kafka/clients/Metadata.java
- clients/src/main/java/org/apache/kafka/clients/MetadataCache.java 34 个添加, 6 个删除...src/main/java/org/apache/kafka/clients/MetadataCache.java
- clients/src/test/java/org/apache/kafka/clients/MetadataCacheTest.java 2 个添加, 1 个删除...test/java/org/apache/kafka/clients/MetadataCacheTest.java
- clients/src/test/java/org/apache/kafka/clients/MetadataTest.java 119 个添加, 10 个删除.../src/test/java/org/apache/kafka/clients/MetadataTest.java
- clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerMetadataTest.java 12 个添加, 3 个删除...afka/clients/consumer/internals/ConsumerMetadataTest.java
- clients/src/test/java/org/apache/kafka/common/requests/RequestTestUtils.java 29 个添加, 8 个删除...va/org/apache/kafka/common/requests/RequestTestUtils.java
加载中
想要评论请 注册 或 登录