From 73a07d7084522d992b6e7d89bd1011a4e259a6c1 Mon Sep 17 00:00:00 2001 From: hcdias Date: Tue, 17 Oct 2023 16:43:57 -0300 Subject: [PATCH] chore: fix kafka parameter --- src/TopicHandler/ConfigOptions/Consumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/TopicHandler/ConfigOptions/Consumer.php b/src/TopicHandler/ConfigOptions/Consumer.php index b89dca15..2d1e173a 100644 --- a/src/TopicHandler/ConfigOptions/Consumer.php +++ b/src/TopicHandler/ConfigOptions/Consumer.php @@ -138,7 +138,7 @@ public function toArray(): array 'auto_commit' => $this->isAutoCommit(), 'commit_async' => $this->isCommitASync(), 'offset_reset' => $this->getOffsetReset(), - 'max_poll_interval' => $this->getMaxPollInterval(), + 'max_poll_interval_ms' => $this->getMaxPollInterval(), ]; if ($avroSchema = $this->getAvroSchema()) {