faaren-tech / kafka-client

此包已被放弃，不再维护。未建议替代包。

简单的 Kafka 包装器

维护者

详细信息

github.com/FAAREN-tech/kafka-client

源代码

问题

安装: 205

依赖: 0

建议者: 0

安全: 0

星标: 2

关注者: 0

分支: 0

开放问题: 0

1.0.0-rc.2 2022-02-10 15:10 UTC

Requires

MIT 3e9c34d2c5e84ae2b093f1734589d0a1207624fd

  • FAAREN <daniel.wyschka.woop@faaren.com>

This package is auto-updated.

Last update: 2023-10-10 19:06:00 UTC

README

此包提供了一个简单的 Kafka-Client-Wrapper，具有 Laravel Facades 和配置

安装

运行以下命令

// Install the package
composer require faaren-tech/kafka-client

// Publish config
php artisan vendor:publish --provider="FaarenTech\KafkaClient\KafkaClientServiceProvider"

配置参数

这些参数已准备就绪，需要添加到您的 .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::topic('TopicName')
                ->buildProducerWithRegistry('BodySchema', 'KeySchema')
                ->message('KeyValue', 'Data2Send', 'headers', 'partition')
                ->produce();
            Producer::flush();

消费者

        $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);
            });
            
        }