From ff6fa2dea00d274adeef7de52b90385ba9f39071 Mon Sep 17 00:00:00 2001 From: hi-rustin Date: Fri, 2 Jun 2023 15:33:49 +0800 Subject: [PATCH] Remove useless code Signed-off-by: hi-rustin --- pkg/sink/kafka/cluster_admin_client_mock_impl.go | 9 --------- 1 file changed, 9 deletions(-) diff --git a/pkg/sink/kafka/cluster_admin_client_mock_impl.go b/pkg/sink/kafka/cluster_admin_client_mock_impl.go index 5a5735630e8..b80ee60cfd6 100644 --- a/pkg/sink/kafka/cluster_admin_client_mock_impl.go +++ b/pkg/sink/kafka/cluster_admin_client_mock_impl.go @@ -103,15 +103,6 @@ func NewClusterAdminClientMockImpl() *ClusterAdminClientMockImpl { } } -// ListTopics returns all topics directly. -func (c *ClusterAdminClientMockImpl) ListTopics() (map[string]sarama.TopicDetail, error) { - topicsDetailsMap := make(map[string]sarama.TopicDetail) - for topic, detail := range c.topics { - topicsDetailsMap[topic] = detail.TopicDetail - } - return topicsDetailsMap, nil -} - // DescribeCluster returns the controller ID. func (c *ClusterAdminClientMockImpl) DescribeCluster() (brokers []*sarama.Broker, controllerID int32, err error) { return nil, c.controllerID, nil