Я использую Kafka с socket-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 года назад, - плохая идея.