wip

Author: mateusjunges

src/Config/Config.php

@@ -141,8 +141,6 @@ public function getConsumerOptions(): array
             'enable.auto.commit' => config('kafka.auto_commit', true) === true ? 'true' : 'false',
             'group.id' => $this->groupId,
             'bootstrap.servers' => $this->broker,
-            'linger.ms' => 0,
-            'queue.buffering.max.ms' => 0,
         ];
 
         if (isset($this->autoCommit)) {
@@ -160,6 +158,8 @@ public function getProducerOptions(): array
             'compression.codec' => config('kafka.compression', 'snappy'),
             'bootstrap.servers' => $this->broker,
             'metadata.broker.list' => $this->broker,
+            'linger.ms' => 0,
+            'queue.buffering.max.ms' => 0
         ];
 
         return collect(array_merge($config, $this->customOptions, $this->getSaslOptions()))