flask - flasfka 包的无效主题错误

Question

我正在使用 Kafka 和 flask-socketIO 进行项目，使用flasfka

按照文档，我正在运行 flasfka 服务器

flasfka-serve

然后做一个简单的 POST 调用来测试它

curl -X POST --data-binary '{"messages": ["msg1", "msg2"]}' "http://127.0.0.1:5000/my-topic/"

但是出现错误

kafka.errors.InvalidTopicError: [Error 17] InvalidTopicError: b'my-topic'
127.0.0.1 - - [04/Jun/2018 11:31:33] "POST /my-topic/ HTTP/1.1" 500

看起来有 500 个内部服务器错误，这太笼统而无法查明。

关于解决它的任何建议？也许使用 3 年前最后更新的包是一个坏主意。