我使用“no kafka”npm包(用于nodejs),我有两个问题:
我的应用程序开始发送消息到一个不存在的主题,我的Kafka选项设置为“自动创建主题”,但当我发送数据到Kafka它不创建主题。
如果我使用Kafka生产者(从控制台)它创建主题,所以问题不在Kafka
如果我使用了不存在的主题,没有kafka停止工作(我希望它听这个主题,即使它不存在,当主题创建和数据到达时,一切都会工作(就像它在kafka控制台中工作一样)
你能帮我解决这些问题吗?
谢谢,拉里
我使用“no kafka”npm包(用于nodejs),我有两个问题:
我的应用程序开始发送消息到一个不存在的主题,我的Kafka选项设置为“自动创建主题”,但当我发送数据到Kafka它不创建主题。
如果我使用Kafka生产者(从控制台)它创建主题,所以问题不在Kafka
如果我使用了不存在的主题,没有kafka停止工作(我希望它听这个主题,即使它不存在,当主题创建和数据到达时,一切都会工作(就像它在kafka控制台中工作一样)
你能帮我解决这些问题吗?
谢谢,拉里
暂无答案!
目前还没有任何答案,快来回答吧!