[kafka] branch trunk updated: MINOR: Remove uncommitted code (#6919)

[davidarthur]

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 <yello1...@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.");