remove unused param

Author: mmreza79

topic_manager.go

@@ -46,10 +46,10 @@ func NewTopicManager(brokers []string, saramaConfig *sarama.Config, topicManager
 	if err != nil {
 		return nil, fmt.Errorf("Error creating the kafka client: %v", err)
 	}
-	return newTopicManager(brokers, saramaConfig, topicManagerConfig, client, checkBroker)
+	return newTopicManager(saramaConfig, topicManagerConfig, client, checkBroker)
 }
 
-func newTopicManager(brokers []string, saramaConfig *sarama.Config, topicManagerConfig *TopicManagerConfig, client sarama.Client, check checkFunc) (*topicManager, error) {
+func newTopicManager(saramaConfig *sarama.Config, topicManagerConfig *TopicManagerConfig, client sarama.Client, check checkFunc) (*topicManager, error) {
 	if client == nil {
 		return nil, errors.New("cannot create topic manager with nil client")
 	}

topic_manager_test.go

@@ -107,7 +107,7 @@ func TestTM_newTopicManager(t *testing.T) {
 		bm.client.EXPECT().Brokers().Return([]*sarama.Broker{
 			new(sarama.Broker),
 		})
-		tm, err := newTopicManager(tmTestBrokers, DefaultConfig(), NewTopicManagerConfig(), bm.client, trueCheckFunc)
+		tm, err := newTopicManager(DefaultConfig(), NewTopicManagerConfig(), bm.client, trueCheckFunc)
 		require.NoError(t, err)
 		require.Equal(t, tm.client, bm.client)
 		require.NotNil(t, tm.admin)
@@ -117,10 +117,10 @@ func TestTM_newTopicManager(t *testing.T) {
 		defer ctrl.Finish()
 		bm := newBuilderMock(ctrl)
 
-		_, err := newTopicManager(tmTestBrokers, nil, nil, bm.client, trueCheckFunc)
+		_, err := newTopicManager(nil, nil, bm.client, trueCheckFunc)
 		require.Error(t, err)
 
-		_, err = newTopicManager(tmTestBrokers, nil, NewTopicManagerConfig(), nil, trueCheckFunc)
+		_, err = newTopicManager(nil, NewTopicManagerConfig(), nil, trueCheckFunc)
 		require.Error(t, err)
 	})
 	t.Run("fail_check", func(t *testing.T) {
@@ -133,7 +133,7 @@ func TestTM_newTopicManager(t *testing.T) {
 			new(sarama.Broker),
 		})
 
-		_, err := newTopicManager(tmTestBrokers, DefaultConfig(), NewTopicManagerConfig(), bm.client, falseCheckFunc)
+		_, err := newTopicManager(DefaultConfig(), NewTopicManagerConfig(), bm.client, falseCheckFunc)
 		require.Equal(t, err.Error(), "broker check error")
 	})
 }