Update for dep change

Mongey · Jan 14, 2018 · 1a19c20 · 1a19c20
1 parent b4f8052
commit 1a19c20
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/kafka/utils.go b/kafka/utils.go
@@ -62,7 +62,7 @@ func ConfigForTopic(topic string, brokers []string) (map[string]string, error) {
 	request := &sarama.DescribeConfigsRequest{
 		Resources: []*sarama.Resource{
 			&sarama.Resource{
-				T:           sarama.TopicResource,
+				Type:        sarama.TopicResource,
 				Name:        topic,
 				ConfigNames: []string{"segment.ms"},
 			},
@@ -121,13 +121,10 @@ func configToResources(topic string, config map[string]*string) []*sarama.AlterC
 
 	for k, v := range config {
 		res[i] = &sarama.AlterConfigsResource{
-			T:    sarama.TopicResource,
+			Type: sarama.TopicResource,
 			Name: topic,
-			ConfigEntries: []*sarama.ConfigEntryKV{
-				&sarama.ConfigEntryKV{
-					Name:  k,
-					Value: *v,
-				},
+			ConfigEntries: map[string]*string{
+				k: v,
 			},
 		}
 		i++