-
-
Notifications
You must be signed in to change notification settings - Fork 100
Open
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
I am unable to auto create topic with consumer, after specifying $consumer->withOption('allow.auto.create.topics', true)->build(); (also check with string "true" value)
To Reproduce
Steps to reproduce the behavior:
- Create consumer with
allow.auto.create.topics: trueconfig that listens to a topic that doesn't exists yet. - Ensure that the broker config is correct -- allows auto creation of topic for the user (for testing use the super user to be absolutely sure).
- Call
$consumer->consume() - Notice error, something like:
{"message":"[CONSUMER] Error to consume message","context":{"message":{"err":3,"topic_name":"mytopic","timestamp":-1,"partition":0,"payload":"Subscribed topic not available: mytopic: Broker: Unknown to ...
{"message":"Broker: Unknown topic or partition","context":{"exception":{"class":"Junges\\Kafka\\Exceptions\\KafkaConsumerException","message":"Broker: Unknown topic or partition","code":3,"file":"/laravel/vendor/mateusjunges/larave ...
In Consumer.php line 410:
Broker: Unknown topic or partition
Expected behavior
Topic should be created with this config, when set with consumer and at the broker level it is allowed.
Additional context
"php": "^8.3",
"ext-rdkafka": "*",
"mateusjunges/laravel-kafka": "^1.13",
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working