configuration.md

Configuration

Installation

composer require ecotone/kafka

Implementation is based on rdkafka.

Configuration

In order to use Kafka Support we need to add KafkaBrokerConfiguration to our Dependency Container.

{% tabs %} {% tab title="Symfony" %}

# config/services.yaml
# You need to have Kafka instance running on your localhost, or change DSN
    Ecotone\Kafka\Configuration\KafkaBrokerConfiguration:
        class: Ecotone\Kafka\Configuration\KafkaBrokerConfiguration
        arguments:
            $bootstrapServers:
                - localhost:9094

{% endtab %}

{% tab title="Laravel" %}

# Register Kafka Service in Provider

use Ecotone\Kafka\Configuration\KafkaBrokerConfiguration;

public function register()
{
     $this->app->singleton(KafkaBrokerConfiguration::class, function () {
         return new KafkaBrokerConfiguration(['localhost:9094']);
     });
}

{% endtab %}

{% tab title="Lite" %}

use Ecotone\Kafka\Configuration\KafkaBrokerConfiguration;

$application = EcotoneLiteApplication::boostrap(
    [
        KafkaBrokerConfiguration::class => new KafkaBrokerConfiguration(['localhost:9094'])
    ]
);

{% endtab %} {% endtabs %}

{% hint style="info" %} We register our KafkaBrokerConfiguration under the class name Ecotone\Kafka\Configuration\KafkaBrokerConfiguration. This will help Ecotone resolve it automatically, without any additional configuration. {% endhint %}