从 Apache Kafka 使用 WSO2ESB JMS 代理

Question

我已经使用 WSO2ESB 和 ActiveMQ 一段时间了。但是，我希望尝试将其切换到 Apache Kafka。

我已经设法让 ESB 生成 Kafka 主题，但我不知道如何让 JMS 代理从此队列中使用。我相当确定这取决于\repository\conf\axis2\axis2.xml 文件中的设置:

       <parameter name="someFactory" locked="false">
            <parameter name="java.naming.factory.initial" locked="false">org.apache.activemq.jndi.ActiveMQInitialContextFactory</parameter>
            <parameter name="java.naming.provider.url" locked="false">tcp://localhost:61610</parameter>
            <parameter name="transport.jms.ConnectionFactoryJNDIName" locked="false">QueueConnectionFactory</parameter>
            <parameter name="transport.jms.ConnectionFactoryType" locked="false">queue</parameter>
        </parameter>

这些设置取自 ActiveMQ 上的 WSO2 示例。我找不到任何与将 WSO2ESB 与 Kafka 结合使用相关的文档，所以我想知道这是否可能？如果是这样，我该如何更改上述设置以使它们进行通信？

Answer 1

WSO2 ESB 4.8.* 或更低版本不支持 kafka，但 ESB 4.9.0 将支持它，因为它仍处于开发阶段，并且 Kafka 支持将作为入站端点(用于监听器)和 ESB 实现连接器(用于发送器)。这些是 ESB 4.9.0 中提供的新 ESB 构造。