我试图使用invokehttp将消息推入我的kafka主题,但它显示了一个连接错误。
a0x5cqrl1#
kafka不接受http连接。你需要使用 PublishKafka 或者 PublishKakfkaRecord .
PublishKafka
PublishKakfkaRecord
1条答案
按热度按时间a0x5cqrl1#
kafka不接受http连接。你需要使用
PublishKafka
或者PublishKakfkaRecord
.