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
相关产品推荐
相关产品推荐

