Skip to content

Commit

Permalink
Remove useless code
Browse files Browse the repository at this point in the history
Signed-off-by: hi-rustin <rustin.liu@gmail.com>
  • Loading branch information
Rustin170506 committed Jun 2, 2023
1 parent d767aeb commit ff6fa2d
Showing 1 changed file with 0 additions and 9 deletions.
9 changes: 0 additions & 9 deletions pkg/sink/kafka/cluster_admin_client_mock_impl.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit ff6fa2d

Please sign in to comment.