openapi

server/app/Services/Kafka/KafkaService.php

@@ -20,7 +20,7 @@ class KafkaService
     public function __construct($config)
     {
         $this->kafkaProducerConfig = $this->getProducerConfig($config);
-        $this->kafkaConsumerConfig = $this->getConsumerConfig($config);
+        //$this->kafkaConsumerConfig = $this->getConsumerConfig($config);
 
         $this->config = $config;
     }
@@ -59,7 +59,7 @@ class KafkaService
      */
     public function startConsumer()
     {
-        $consumer = new Consumer($this->kafkaConsumerConfig, function (ConsumeMessage $message) {
+        $consumer = new Consumer($this->getConsumerConfig($this->config), function (ConsumeMessage $message) {
 
             $consumer = $message->getConsumer();
             $kafkaMessage = json_decode($message->getValue(),true);