Configuring your kafka producer
The producer builder, returned by the publish
call, gives you a series of methods which you can use to configure your kafka producer options.
Support Laravel Kafka by sponsoring me!
Do you find Laravel Kafka valuable and wanna support its development?
Laravel Kafka is free and Open Source software, built to empower developers like you. Your support helps maintain and enhance the project. If you find it valuable, please consider sponsoring me on GitHub. Every contribution makes a difference and keeps the development going strong! Thank you!
Defining configuration options
The withConfigOption
method sets a \RdKafka\Conf::class
option. You can check all available options here .
This method sets one config per call, and you can use withConfigOptions
passing an array of config name and config value
as argument. Here's an example:
use Junges\Kafka\Facades\Kafka; Kafka::publish('broker') ->onTopic('topic') ->withConfigOption('property-name', 'property-value') ->withConfigOptions([ 'property-name' => 'property-value' ]);
While you are developing your application, you can enable debug with the withDebugEnabled
method.
To disable debug mode, you can use ->withDebugEnabled(false)
, or withDebugDisabled
methods.
use Junges\Kafka\Facades\Kafka; Kafka::publish('broker') ->onTopic('topic') ->withConfigOption('property-name', 'property-value') ->withConfigOptions([ 'property-name' => 'property-value' ]) ->withDebugEnabled() // To enable debug mode ->withDebugDisabled() // To disable debug mode ->withDebugEnabled(false) // Also to disable debug mode