From 2c8972d7a31276191797e05adb2d65a558823f0e Mon Sep 17 00:00:00 2001
From: Leonardus Windiono <windio@accelbyte.net>
Date: Mon, 13 May 2024 14:18:09 +0700
Subject: [PATCH] fix(v3): race condition set AllowAutoTopicCreation (#75)

---
 v3/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/v3/kafka.go b/v3/kafka.go
index 2155d26..2b88b10 100644
--- 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