Chore: fix typo

asheswook · asheswook · commit dc671c329f3b · 2024-07-23T13:03:25.000+09:00
diff --git a/internal/queue/kafka/operator.go b/internal/queue/kafka/operator.go
@@ -162,7 +162,7 @@ func (k *BytesProduceOperator) Produce(message []byte) error {
 	}
 
 	producer.Input() <- &sarama.ProducerMessage{
-		Topic: k.brokers[0],
+		Topic: k.topic,
 		Value: sarama.ByteEncoder(message),
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -162,7 +162,7 @@ func (k *BytesProduceOperator) Produce(message []byte) error {`
`162`	`162`	`}`
`163`	`163`
`164`	`164`	`producer.Input() <- &sarama.ProducerMessage{`
`165`		`- Topic: k.brokers[0],`
	`165`	`+ Topic: k.topic,`
`166`	`166`	`Value: sarama.ByteEncoder(message),`
`167`	`167`	`}`
`168`	`168`