問(wèn)題現(xiàn)象
在云消息隊(duì)列 Kafka 版控制臺(tái)的Topic 管理頁(yè)面,您已成功創(chuàng)建Topic,但使用Filebeat向該Topic發(fā)送消息卻出現(xiàn)Request was for a topic or partition that does not exist on this broker.的錯(cuò)誤提示。
可能原因
Filebeat向Topic發(fā)送消息時(shí),會(huì)自動(dòng)將Topic名稱(chēng)中的大寫(xiě)字母轉(zhuǎn)換成小寫(xiě)字母。例如,您使用Filebeat向名稱(chēng)為AAA的Topic發(fā)送消息時(shí),F(xiàn)ilebeat會(huì)自動(dòng)轉(zhuǎn)換成向名稱(chēng)為aaa的Topic發(fā)送消息。由于發(fā)送消息的請(qǐng)求無(wú)法找到訂閱的Topic,所以出現(xiàn)Request was for a topic or partition that does not exist on this broker.的錯(cuò)誤提示。
解決方案
在云消息隊(duì)列 Kafka 版控制臺(tái)的Topic 管理頁(yè)面創(chuàng)建Topic,請(qǐng)使用全小寫(xiě)字母給Topic命名。