check kafka produce out-of-order IBM/sarama#2619

wk989898 · Jun 4, 2024 · ae93222 · ae93222
1 parent 5e0c851
commit ae93222
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/sink/kafka/sarama.go b/pkg/sink/kafka/sarama.go
@@ -70,6 +70,7 @@ func NewSaramaConfig(ctx context.Context, o *Options) (*sarama.Config, error) {
 	config.Net.DialTimeout = o.DialTimeout
 	config.Net.WriteTimeout = o.WriteTimeout
 	config.Net.ReadTimeout = o.ReadTimeout
+	config.Net.MaxOpenRequests = 1
 
 	config.Producer.Partitioner = sarama.NewManualPartitioner
 	config.Producer.MaxMessageBytes = o.MaxMessageBytes