go-queue
go-queue copied to clipboard
auto topic creation enabled
trafficstars
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.
anyone can review and merge this PR?
It's better to be a passed in option. Not just allowing the topic auto creation.
This feature has been implemented by https://github.com/zeromicro/go-queue/pull/54 . This issue can be closed now.