faaren-tech / kafka-client
This package is abandoned and no longer maintained.
No replacement package was suggested.
Simple Kafka Wrapper
1.0.0-rc.2
2022-02-10 15:10 UTC
Requires
- flix-tech/avro-serde-php: ~1.4
- jobcloud/php-kafka-lib: ~1.4
This package is auto-updated.
Last update: 2023-10-10 19:06:00 UTC
README
This package offers a simple Kafka-Client-Wrapper with Laravel Facades and configs
Installation
Run the following commands:
// Install the package
composer require faaren-tech/kafka-client
// Publish config
php artisan vendor:publish --provider="FaarenTech\KafkaClient\KafkaClientServiceProvider"
Configuration Parameter
The parameters are prepared and needs to be added to your .env
FAA_KAFKA_REGISTRY_URL=XXXX
FAA_KAFKA_REGISTRY_AUTH_USER=XXXX
FAA_KAFKA_REGISTRY_AUTH_PASSWORD=XXXX
FAA_KAFKA_BROKER_URL=XXXX
FAA_KAFKA_BROKER_AUTH_USER=XXXX
FAA_KAFKA_BROKER_AUTH_PASSWORD=XXXX
FAA_KAFKA_CONSUMER_GROUP_ID=XXXX
Producer
Producer::topic('TopicName') ->buildProducerWithRegistry('BodySchema', 'KeySchema') ->message('KeyValue', 'Data2Send', 'headers', 'partition') ->produce(); Producer::flush();
Consumer
$consumer = Consumer::topic('TopicName') ->buildConsumerWithRegistry('BodySchema', 'KeySchema') ->subscribe(); while(true) { /** * First Parameter, is the Timeout in ms, Second Parameter is the Auto-Decode Option */ $consumer->consume(5000, false, function($consumer, $message){ //to "commit" the message, please use the ack method $consumer->ack($message); }); }