WSO2ESB 来自 Apache Kafka 的 JMS 代理消费

Question

我已经在ActiveMQ中使用WSO2ESB一段时间了。 但是，我想尝试将其换成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 示例。 我找不到任何与使用 Kafka WSO2ESB相关的文档，所以我想知道这是否可能？ 如果是这样，如何更改上述设置以使它们进行通信？

Answer 1

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

Answer 2

WSo2 ESB 4.9 将于 2015 年第 1 季度末发布。

Answer 3

Kafka 入站端点已随 ESB 4.9.0 一起发布，用于使用队列中的数据。在博客中，对 ESB 4.9.0 的 Kafka 支持进行了说明，包括用例以及如何使用入站线程池调整 Kafka 入站端点的性能。