init

Author: soulaimaneyahyax

.editorconfig

@@ -0,0 +1,15 @@
+root = true
+
+[*]
+charset = utf-8
+end_of_line = lf
+insert_final_newline = true
+indent_style = space
+indent_size = 4
+trim_trailing_whitespace = true
+
+[*.md]
+trim_trailing_whitespace = false
+
+[*.{yml,yaml}]
+indent_size = 2

.env.example

@@ -0,0 +1,3 @@
+KAFKA_BOOTSTRAP_SERVERS=<kafka-bootstrap-servers>
+KAFKA_TOPIC_NAME=<kafka-topic-name>
+KAFKA_GROUP_ID=<kafka-group-id>

.github/workflows/ci.yml

@@ -0,0 +1,40 @@
+name: CI
+
+on:
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+permissions:
+  contents: read
+
+jobs:
+  build:
+
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Set up PHP
+        uses: shivammathur/setup-php@15c43e89cdef867065b0213be354c2841860869e
+        with:
+          php-version: "8.2"
+
+      - name: Install PHP dependencies
+        run: |
+          sudo apt-get update
+          sudo apt-get install -y librdkafka-dev
+          sudo pecl install rdkafka
+          echo "extension=rdkafka.so" | sudo tee -a /etc/php/8.3/cli/php.ini
+
+      - name: Checkout code
+        uses: actions/checkout@v3
+
+      - name: Validate composer.json and composer.lock
+        run: composer validate --strict
+
+      - name: Install dependencies
+        run: composer install --prefer-dist --no-interaction --no-progress
+
+      - name: Validate PHP PSR
+        run: composer run-script php-fixer

.gitignore

@@ -0,0 +1,2 @@
+/vendor
+.env

README.md

@@ -0,0 +1,23 @@
+# kafka-queue
+
+- https://arnaud-lb.github.io/php-rdkafka-doc/phpdoc/rdkafka.installation.html
+
+installing
+```sh
+composer require multividas/kafka-queue:dev-main --dev
+```
+
+### 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.

composer.json

@@ -0,0 +1,35 @@
+{
+    "name": "multividas/kafka-queue",
+    "license": "MIT",
+    "description": "Kafka Queue for PHP",
+    "authors": [
+        {
+            "name": "Soulaimane Yahya",
+            "email": "[email protected]"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "Kafka\\": "src/"
+        }
+    },
+    "require": {
+        "php": "^8.2",
+        "laravel/lumen-framework": "^10.0",
+        "squizlabs/php_codesniffer": "^3.7",
+        "jobcloud/php-kafka-lib": "^2.0"
+    },
+    "scripts": {
+        "php-fixer": [
+            "./vendor/bin/phpcs src --standard=PSR2"
+        ]
+    },
+    "extra": {
+      "laravel": {
+        "providers": [
+          "Kafka\\Providers\\KafkaServiceProvider"
+        ]
+      }
+    },
+    "minimum-stability": "dev"
+}