fixing-kafka-connector

Author: soulaimaneyahyax

.env.example

@@ -1,7 +1,7 @@
-KAFKA_QUEUE=your_kafka_topic
-KAFKA_BOOTSTRAP_SERVERS=localhost:9092
-KAFKA_SECURITY_PROTOCOL=SASL_SSL
-KAFKA_SASL_MECHANISMS=PLAIN
-KAFKA_SASL_USERNAME=your_kafka_username
-KAFKA_SASL_PASSWORD=your_kafka_password
-KAFKA_GROUP_ID=your_consumer_group
+KAFKA_QUEUE=<kafka-topic>
+KAFKA_BOOTSTRAP_SERVERS=<kafka-bootstrap-servers>
+KAFKA_SECURITY_PROTOCOL=<kafka-security-protocol>
+KAFKA_SASL_MECHANISMS=<kafka-sasl-mechanisms>
+KAFKA_SASL_USERNAME=<kafka-sasl-username>
+KAFKA_SASL_PASSWORD=<kafka-sasl-password>
+KAFKA_GROUP_ID=<kafka-group-id>

README.md

@@ -1,3 +1,18 @@
 # kafka-queue
 
 - https://arnaud-lb.github.io/php-rdkafka-doc/phpdoc/rdkafka.installation.html
+
+### ServiceProvider (KafkaServiceProvider):
+
+- Registers the Kafka queue connector with Laravel's queue manager.
+
+### Implements the QueueContract interface.
+
+- Provides methods like push, pop, and size for interacting with Kafka.
+- push() pushes a serialized job to Kafka using the producer.
+- pop() consumes messages from Kafka and processes jobs.
+
+### Connector Class (KafkaConnector):
+
+- Implements the ConnectorInterface.
+- Sets up Kafka producer and consumer.

src/Providers/KafkaServiceProvider.php

@@ -4,11 +4,16 @@
 
 namespace Kafka\Providers;
 
+use Kafka\Services\KafkaConnector;
 use Illuminate\Support\ServiceProvider;
 
 class KafkaServiceProvider extends ServiceProvider
 {
-    public function boot()
+    public function boot(): void
     {
+        /** @var QueueManager $queue */
+        $queue = $this->app->make('queue');
+
+        $queue->addConnector('kafka', static fn () => new KafkaConnector());
     }
 }