fix(v3): race condition set AllowAutoTopicCreation (#75)

AccelByte · May 13, 2024 · 2c8972d · 2c8972d
1 parent 260a52a
commit 2c8972d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/v3/kafka.go b/v3/kafka.go
@@ -359,7 +359,6 @@ func (client *KafkaClient) publishEvent(ctx context.Context, topic, eventName st
 
 	config.Topic = topic
 	writer = client.getWriter(config)
-	writer.AllowAutoTopicCreation = true
 	err = writer.WriteMessages(ctx, message)
 	if err != nil {
 		if errors.Is(err, io.ErrClosedPipe) {
@@ -663,6 +662,7 @@ func (client *KafkaClient) getWriter(config kafka.WriterConfig) *kafka.Writer {
 	}
 
 	writer := kafka.NewWriter(config)
+	writer.AllowAutoTopicCreation = true
 	client.writers[config.Topic] = writer
 
 	return writer