You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2019/06/12 13:33:20 UTC
[kafka] branch trunk updated: MINOR: Remove uncommitted code (#6919)
This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new e2c15e0 MINOR: Remove uncommitted code (#6919)
e2c15e0 is described below
commit e2c15e0eeb8e853aead9ef5e307930fd781b38e4
Author: highluck <ye...@daum.net>
AuthorDate: Wed Jun 12 22:33:03 2019 +0900
MINOR: Remove uncommitted code (#6919)
---
clients/src/main/java/org/apache/kafka/clients/MetadataCache.java | 7 -------
1 file changed, 7 deletions(-)
diff --git a/clients/src/main/java/org/apache/kafka/clients/MetadataCache.java b/clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
index b5c9de6..e58da12 100644
--- a/clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
+++ b/clients/src/main/java/org/apache/kafka/clients/MetadataCache.java
@@ -97,13 +97,6 @@ public class MetadataCache {
return Optional.ofNullable(metadataByPartition.get(topicPartition));
}
- synchronized void retainTopics(Collection<String> topics) {
- metadataByPartition.entrySet().removeIf(entry -> !topics.contains(entry.getKey().topic()));
- unauthorizedTopics.retainAll(topics);
- invalidTopics.retainAll(topics);
- computeClusterView();
- }
-
Cluster cluster() {
if (clusterInstance == null) {
throw new IllegalStateException("Cached Cluster instance should not be null, but was.");