chore: fix

Trendyol · Nov 13, 2023 · 3a3480b · 3a3480b
1 parent fb999bc
commit 3a3480b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/kafka/metadata/kafka_metadata.go b/kafka/metadata/kafka_metadata.go
@@ -135,14 +135,14 @@ func (s *kafkaMetadata) Clear(_ []uint16) error {
 
 func NewKafkaMetadata(
 	kafkaClient gKafka.Client,
-	kafkaMetadataConfig map[string]string,
+	kafkaMetadataConfig map[string]any,
 ) metadata.Metadata {
 	var topic string
 	var partition int
 	var replicationFactor int
 
 	if _, ok := kafkaMetadataConfig["topic"]; ok {
-		topic = kafkaMetadataConfig["topic"]
+		topic = kafkaMetadataConfig["topic"].(string)
 	} else {
 		panic(errors.New("topic is not defined"))
 	}
@@ -152,7 +152,7 @@ func NewKafkaMetadata(
 	}
 
 	if _, ok := kafkaMetadataConfig["partition"]; ok {
-		partition, _ = strconv.Atoi(kafkaMetadataConfig["partition"])
+		partition, _ = strconv.Atoi(kafkaMetadataConfig["partition"].(string))
 	} else {
 		partition = 25
 	}
@@ -162,7 +162,7 @@ func NewKafkaMetadata(
 	}
 
 	if _, ok := kafkaMetadataConfig["replicationFactor"]; ok {
-		replicationFactor, _ = strconv.Atoi(kafkaMetadataConfig["replicationFactor"])
+		replicationFactor, _ = strconv.Atoi(kafkaMetadataConfig["replicationFactor"].(string))
 	} else {
 		replicationFactor = 3
 	}

diff --git a/test/integration/integration_test.go b/test/integration/integration_test.go
@@ -52,7 +52,7 @@ func TestKafka(t *testing.T) {
 			},
 			Metadata: dcpConfig.Metadata{
 				ReadOnly: true,
-				Config: map[string]string{
+				Config: map[string]any{
 					"bucket":     "dcp-test",
 					"scope":      "_default",
 					"collection": "_default",