Attempt to fix consumers not working

mateusjunges · May 14, 2024 · 8e31d3b · 8e31d3b
1 parent a0673a4
commit 8e31d3b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/Config/Config.php b/src/Config/Config.php
@@ -141,6 +141,8 @@ 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)) {