You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

WSO2微集成器无法从WSL2部署的Kafka主题消费消息求助

WSL2 Kafka 与 WSO2 微集成器入站端点消费失败问题

环境与现状:

  • WSL2 中部署 Kafka,实例内部可正常生产、消费demo-test主题的消息
  • Windows 本地部署 WSO2 微集成器,通过 Kafka 连接器已成功向该主题发送 JSON 格式消息
  • 按照官方文档配置 Kafka 入站端点尝试消费消息时失败,微集成器持续报错无法连接主题并消费(日志截图见链接)

入站端点配置:

<?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint class="org.wso2.carbon.inbound.kafka.KafkaMessageConsumer" name="kafkaListenerInboundEp" onError="kafkaListenerSequence" sequence="kafkaListenerSequence" suspend="false" xmlns="http://ws.apache.org/ns/synapse">
    <parameters>
        <parameter name="bootstrap.servers">localhost:9092</parameter>
        <parameter name="topic.name">demo-test</parameter>
        <parameter name="group.id">test-consumer-group</parameter>
        <parameter name="key.deserializer">org.apache.kafka.common.serialization.StringDeserializer</parameter>
        <parameter name="value.deserializer">org.apache.kafka.common.serialization.StringDeserializer</parameter>
        <parameter name="poll.timeout">1000</parameter>
        <parameter name="contentType">application/json</parameter>
        <parameter name="interval">1000</parameter>
        <parameter name="class">org.wso2.carbon.inbound.kafka.KafkaMessageConsumer</parameter>
        <parameter name="sequential">true</parameter>
        <parameter name="coordination">true</parameter>
        <parameter name="inbound.behavior">polling</parameter>
    </parameters>
</inboundEndpoint>

恳请各位帮忙排查问题,给出解决建议!

内容的提问来源于stack exchange,提问作者ahinsa

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.20 08:13:16