Fix lint

Trendyol · Mar 20, 2023 · 0958e75 · 0958e75
1 parent c2eb5d8
commit 0958e75
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 2 deletions.
diff --git a/kafka/producer/producer.go b/kafka/producer/producer.go
@@ -50,7 +50,13 @@ func NewProducer(config *config.Kafka, logger logger.Logger, errorLogger logger.
 		writer.Transport = transport
 	}
 	return &producer{
-		producerBatch: newProducerBatch(config.ProducerBatchTickerDuration, writer, config.ProducerBatchSize, logger, errorLogger, dcpCheckpointCommit),
+		producerBatch: newProducerBatch(
+			config.ProducerBatchTickerDuration,
+			writer,
+			config.ProducerBatchSize,
+			logger,
+			errorLogger,
+			dcpCheckpointCommit),
 	}
 }
 

diff --git a/kafka/producer/producer_batch.go b/kafka/producer/producer_batch.go
@@ -24,7 +24,14 @@ type producerBatch struct {
 	flushLock           sync.Mutex
 }
 
-func newProducerBatch(batchTime time.Duration, writer *kafka.Writer, batchLimit int, logger logger.Logger, errorLogger logger.Logger, dcpCheckpointCommit func()) *producerBatch {
+func newProducerBatch(
+	batchTime time.Duration,
+	writer *kafka.Writer,
+	batchLimit int,
+	logger logger.Logger,
+	errorLogger logger.Logger,
+	dcpCheckpointCommit func(),
+) *producerBatch {
 	batch := &producerBatch{
 		batchTickerDuration: batchTime,
 		batchTicker:         time.NewTicker(batchTime),