使用 Kafka 实现 STOMP 协议

Question

我正在使用 websocket 协议和 STOMP 作为消息协议为网络平台开发聊天模块。

这是我第一次使用任何消息代理，Kafka 是在公司（我正在工作的）网络平台上使用的消息代理，我猜是用于其他模块。之前我刚开始时使用的是 RabbitMQ，现在我必须切换到 Kafka。我在RabbitMQ的网站上看到有一整篇关于如何使用STOMP的文章，但是Kafka的官方网站上没有这样的东西。

但我探索了其他几个来源、许多教程，但找不到任何与 Kafka 一起使用 STOMP 协议相关的内容，这让我问这是否可能？

这是我的 websocket 配置类：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer{

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app");
        registry.enableSimpleBroker("/topic");

//Here's the line I wrote to use Kafka as a MB, but doesn't work        
registry.enableStompBrokerRelay("/topic").setRelayHost("localhost").setRelayPort(9092);

启动 Kafka，然后运行我的 Java Spring 应用程序后，我从 java.io.IOException 中收到“连接由对等方重置”，如果一切正常，则不应抛出该异常。

我使用 Kakfa 的 2.2.0 版本、Zookeeper 的 3.4.14 版本，并使用 STS 3 作为我的 IDE。

任何帮助，将不胜感激。

Answer 1

RabbitMQ本身并不支持STOMP，但它有一个STOMP插件；Kafka 没有对 STOMP 的内置支持。