fixing-changes

Author: soulaimaneyahyax

.env.example

@@ -1,3 +1,14 @@
-KAFKA_BOOTSTRAP_SERVERS=<kafka-bootstrap-servers>
-KAFKA_TOPIC_NAME=<kafka-topic-name>
-KAFKA_GROUP_ID=<kafka-group-id>
+CACHE_DRIVER=file
+
+QUEUE_CONNECTION=kafka
+KAFKA_TOPIC_NAME=categories-topic
+KAFKA_GROUP_ID=categories-group
+KAFKA_QUEUE=default
+KAFKA_CONSUMER_GROUP_ID=categories-group
+KAFKA_BROKERS=localhost:9092
+KAFKA_ERROR_SLEEP=5
+KAFKA_DEADLOCK_SLEEP=2
+KAFKA_SASL_ENABLE=false
+KAFKA_SSL_CA_LOCATION=
+KAFKA_SASL_PLAIN_USERNAME=
+KAFKA_SASL_PLAIN_PASSWORD=

src/Services/KafkaConnector.php

@@ -24,15 +24,15 @@ public function connect(array $config): KafkaQueue
     protected function createProducer(array $config): KafkaProducerInterface
     {
         return KafkaProducerBuilder::create()
-            ->withAdditionalBroker($config['bootstrap-servers'])
+            ->withAdditionalBroker($config['brokers'])
             ->build();
     }
 
     protected function createConsumer(array $config): KafkaConsumerInterface
     {
         return KafkaConsumerBuilder::create()
-            ->withAdditionalBroker($config['bootstrap-servers'])
-            ->withConsumerGroup($config['group-id'])
+            ->withAdditionalBroker($config['brokers'])
+            ->withConsumerGroup($config['consumer_group_id'])
             ->withAdditionalSubscription($config['topic-name'])
             ->build();
     }

src/Services/KafkaQueue.php

@@ -124,23 +124,4 @@ public function bulk($jobs, $data = '', $queue = null)
     public function pop($queue = null)
     {
     }
-
-    /**
-     * Get the connection name for the queue.
-     *
-     * @return string
-     */
-    public function getConnectionName()
-    {
-    }
-
-    /**
-     * Set the connection name for the queue.
-     *
-     * @param  string  $name
-     * @return $this
-     */
-    public function setConnectionName($name)
-    {
-    }
 }