laravel-kafka

laravel-kafka copied to clipboard

Hi, I'm using [laravel-opcache](https://github.com/appstract/laravel-opcache) and [laravel-octane-dockerfile](https://github.com/exaco/laravel-octane-dockerfile) with Laravel Octane. Before starting the server and after running `php artisan compile` command to pre-compile application code (includes `vendor` directory), the following error...

smortexa

[QUESTION] Commit and Error Handling

1

Hi, I am wondering how does the `autoCommit()` feature works with the message handler if it throws an error? Given I have the following, if I run the command, the...

francoisauclair911

Hello! I am trying to figure out if a healthcheck can be configured or added. When I start the consumer in our kubernetes cluster it takes a solid 30 seconds...

TigoCoinmerce

I have this code in a Laravel Command: ```php Kafka::createConsumer() ->subscribe($this->topic) ->withConsumerGroupId(config('kafka.consumer_group_id')) ->withHandler(fn (KafkaConsumerMessage $message) => $this->handler($handler, $message)) ->stopAfterLastMessage() ->build() ->consume(); ``` This command is executed in a cronjob every...

eusonlito

[QUESTION] Example Using Custom Commiter

2

Hi, thanks for creating this package. I'm using this and works great so far. But I'm having difficulty to find some example for using custom commiter in this documentation https://junges.dev/documentation/laravel-kafka/v1.7/advanced-usage/4-custom-committers...

tharyono

Just a test for now, not sure if Im going to merge it

mateusjunges

I would like to retry publishing events if an error occurs

higaooliveira

cant send message

7

hi my laravel version is 11 php version 8.3.8 i can send data to specific topic with this custom class: ```php

RezaZkr

Hi there, We quite often experience the error "Specified group generation id is not valid" when consuming messages for some of our topics: ``` {"throwable":{"file":"/app/vendor/mateusjunges/laravel-kafka/src/Commit/KafkaCommitter.php:20","code":22,"message":"Broker: Specified group generation id is...

kiessan

TLS Authentication

5

Hello there, This is primarily a follow-up on #127, which resolved concerns regarding SASL_SSL but not for instances that require TLS. When connecting to my Kafka instance, I have to...

corsair