Skip to content

Conversation

mirwaisx
Copy link

Hi
Tested with Strimzi Kafka and was getting this error when pushing with Pusher.push which in turns calls Kafka.writer.writemessage.
Unknown Topic Or Partition: the request is for a topic or partition that does not exist on this broker

Apparently accoding to this: segmentio the AllowAutoTopicCreation in Writer should be set to true.

@mirwaisx
Copy link
Author

anyone can review and merge this PR?

@kevwan
Copy link
Contributor

kevwan commented Oct 2, 2023

It's better to be a passed in option. Not just allowing the topic auto creation.

@algobot76
Copy link
Contributor

This feature has been implemented by #54 . This issue can be closed now.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants