KafkaError{code=_UNKNOWN_TOPIC，val=-188，str= "Unable to produce message: Local: Unknown topic" } 错误，

Question

我正在使用kafka生产者的python脚本，并得到以下错误:

cimpl.KafkaException: KafkaError{code=_UNKNOWN_TOPIC,val=-188,str="Unable to produce message: Local: Unknown topic"}

我得到以下错误:

cimpl.KafkaException: KafkaError{code=_UNKNOWN_TOPIC,val=-188,str="Unable to produce message: Local: Unknown topic"}
%4|1668330504.791|TERMINATE|rdkafka#producer-1| [thrd:app]: Producer terminating with 320 messages (1006004 bytes) still in queue or transit: use flush() to wait for outstanding message delivery

Answer 1

看起来您要生成的主题不存在。可以使用create命令创建主题。点击这里阅读更多内容