rossel/rossel-kafka

There is no license information available for the latest version (0.4.0-alpha-11) of this package.

A ready-to-use PHP library for seamless communication with Rossel's Kafka infrastructure, handling both production and consumption of messages.

0.4.0-alpha-11 2026-05-05 14:39 UTC

Requires

• php: >= 8.2
• enqueue/enqueue-bundle: ^0.10.24
• enqueue/fs: ^0.10.19
• enqueue/rdkafka: ^0.10.20
• phpstan/phpstan: ^2.1
• psr/log: ^3.0
• ramsey/uuid: ^4.7
• symfony/config: ^6.4 || ^7.0
• symfony/console: ^6.4 || ^7.0
• symfony/dependency-injection: ^6.4 || ^7.0
• symfony/http-kernel: ^6.4 || ^7.0
• symfony/options-resolver: ^6.4 || ^7.0
• symfony/process: ^7.4

Requires (Dev)

• phpstan/phpstan-phpunit: ^2.0
• phpunit/phpunit: ^11

Unknown License

• Florian Vaneste
• Sébastien Gosselin

README

A ready-to-use PHP library for seamless communication with Rossel's Kafka infrastructure, handling both production and consumption of messages.

Installation

composer require rossel/rossel-kafka

Configuration

Bundle configuration

rossel_kafka:
  broker_url: %env(KAFKA_BROKER_URL)%

Broker configuration (docker)

// WIP

Usage

Send a message to a topic

Without Symfony Dependency Injection

use Rossel\RosselKafka\Service\Connector\KafkaConnector;
use Rossel\RosselKafka\Enum\Infrastructure\KafkaTopic;
use Rossel\RosselKafka\Model\Message;
use Rossel\RosselKafka\Model\MessageHeaders;
use Rossel\RosselKafka\Enum\MessageHeaders\Area;

$kafkaConnector = new KafkaConnector(
    brokerUrl: 'localhost:9092',
);

$message = new Message(
    headers: new Rossel\RosselKafka\Model\MessageHeaders(
        area: Area::FRANCE,
        from: 'my-app',
        messageType: \Rossel\RosselKafka\Enum\MessageHeaders\MessageType::SYNC_B2C_ERP_SUBSCRIPTION,
    ),
    body: [
        'foo' => 'bar',
    ],
)

$kafkaConnector->send(KafkaTopic::SYNC_ERP, $message);