我正在尝试找到一种方法来使用由 websocket 发送到 kafka 主题的消息（消息由 websocket 发送到地址“ws://address:port/topic_name”，我想添加所有这些发送到 kafka 主题的消息）。我读到了有关 kafka connect 的内容，并试图找到一种方法来使用它，但它似乎不起作用......提前感谢:)
websocket apache-kafka
apache-kafka ×1
websocket ×1