gobmp
gobmp copied to clipboard
createTopic timeouts
ensureTopic method does not have an actual timeout for topic creation, and it seems default value for this is "0", yes an actual zero. So it fails to create topics at least in our environment
adding Timeout: timeout, at line 236 in kafka-publisher.go worked for us.
https://github.com/Shopify/sarama/pull/1142