Comments (10)
@aungmyatmoethegreat I just cloned your repo, ran docker compose up -d --build
and executed the saga:listen
and saga:produce
commands. I can listen to the messages just fine:
from laravel-kafka.
Hey there, this is now working well now. I just updated for your reference. It's not an issue with this lib at all. It's an issue of Bitnami image's KRAFT listener issue.
from laravel-kafka.
@aungmyatmoethegreat in your first version you mentioned it stopped working after you upgraded to Laravel 11. Can you reproduce this issue in a fresh laravel installation?
from laravel-kafka.
@aungmyatmoethegreat in your first version you mentioned it stopped working after you upgraded to Laravel 11. Can you reproduce this issue in a fresh laravel installation?
Yes I can,
from laravel-kafka.
@mateusjunges I just installed it in a fresh Laravel and Docker setup. There's still an issue with listening, although it works well for producing messages.
https://github.com/aungmyatmoethegreat/kafka-reproduce
from laravel-kafka.
I started to worry about the Bitnami Kafka image, so I tested with Confluent Cloud, and the same issue still persists. I can produce the message, but consuming in Laravel Kafka is still an issue. Additionally, I noticed that I have to append ->withSasl()
to the config all the time, as the environment variables are not even loaded.
KAFKA_BROKERS=pkc-12576z.us-west2.gcp.confluent.cloud:9092
KAFKA_SECURITY_PROTOCOL=SASL_SSL
KAFKA_MECHANISMS=PLAIN
KAFKA_USERNAME=
KAFKA_PASSWORD=
![Screenshot 2024-05-15 at 7 50 02 PM](https://private-user-images.githubusercontent.com/65492233/330820283-5ba62bc9-a758-432a-9a2d-2f72e585897a.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjE1MDY1ODcsIm5iZiI6MTcyMTUwNjI4NywicGF0aCI6Ii82NTQ5MjIzMy8zMzA4MjAyODMtNWJhNjJiYzktYTc1OC00MzJhLTlhMmQtMmY3MmU1ODU4OTdhLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA3MjAlMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNzIwVDIwMTEyN1omWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTI1ZjRhNWM3ZTFiOTc0ZWZiYWFhNTRlY2EwOGM0NTVlYjA1NTVmNmVhNjFjNGY4MDhlMmFkMDAxZGJmODFlYjImWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.oUQZ1NIegx43sr-0-O188KJknkDk0ithas67GueFsfA)
from laravel-kafka.
I'll check out the demo repo in later today. About the ->withSasl
call, you have to add it when you are using sasl, the env keys are there only to prevent you from adding it directly to the codebase
from laravel-kafka.
Okay thank you for the Sasl reference. But please look the consuming process.
from laravel-kafka.
Okay, I would like to test again. What runtime do you use for the docker? Could you please specify your docker runtime? I am currently using orbstack instead of docker desktop.
from laravel-kafka.
I just updated config to use docker instead of confluent cloud. Working with confluents is fine. But it's still an issue with kafk-cp or bitnami kafka.
from laravel-kafka.
Related Issues (20)
- Have to specify topic name in each Message HOT 3
- Failed to resolve `broker:9092` HOT 4
- Getting a timeout issue, while trying to publish a message. HOT 7
- Undefined constant \"Junges\\Kafka\\RD_KAFKA_PARTITION_UA\ HOT 3
- Upstash Support - Producer not sending messages. HOT 3
- Wrong return type in Junges\Kafka\Config\Config->getCommit HOT 2
- Cannot Consume published messages in laravel 11 and php 8.3.6 HOT 15
- Issue consuming records from Avro topic HOT 1
- Cannot consume produced messages in v2.0 HOT 2
- What do we need to set for the `--consumer` flag. HOT 1
- Encoded payloads: Is it possible with Avro Serializer to Save encoded messages in Kafka when sending it using AvroSerialize and doing the opposite when reading with Deserializer HOT 1
- Is there any support to Retry policies ? HOT 2
- [QUESTION] Possibility to describe topic / calculate read backlog HOT 1
- [Question/bug] Consuming Tombstones and send it to dlq throws $payload must be of type string, null given HOT 1
- cant send message HOT 7
- Error "Specified group generation id is not valid" during consumption HOT 1
- How to commit each message in withHandler
- Missing messages HOT 2
- Customizable flush retried and timeout
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from laravel-kafka.