WSO2 Micro Integrator 是否支持 Kafka 2.3.1 Inbound Endpoint 从 Kafka 读取消息？

【问题标题】：Does WSO2 Micro Integrator Supports Kafka 2.3.1 Inbound Endpoint to read messages from Kafka?WSO2 Micro Integrator 是否支持 Kafka 2.3.1 Inbound Endpoint 从 Kafka 读取消息？
【发布时间】：2020-04-27 20:30:01
【问题描述】：

'我正在开发一个 Kafka 集成，我在其中发布和读取来自主题的消息。我能够将消息发布到主题，但无法使用入站端点读取这些消息。当我查看 WSO2 文档时，他们推荐使用非常古老的 Kafka kafka_2.9.2-0.8.1.1。我们不能使用最新版本的 Kafka 和 Micro Integrator 吗？任何人都可以建议。'

【问题讨论】：

我可以在文档中看到Kafka 2.12-0.11.0.0，这对后来的经纪人来说很好用。你在看什么？

标签： apache-kafka wso2 wso2esb wso2mi

【解决方案1】：

如果您使用 WSO2 连接器存储中的 Kafka 入站端点，那么您应该能够使用最新版本。查看此文档https://github.com/wso2-extensions/esb-inbound-kafka/blob/release-1.0.7/docs/config.md

还可以查看这个 github 问题线程 https://github.com/wso2/product-ei/issues/2239

【讨论】：

嗨 Arunan，根据您提供的 WSO2 链接，建议 kafka 版本是 kafka_2.12-1.0.0，但我们使用的是 2.3.1。我正在使用来自 wso2 连接器存储的入站端点。但我得到了错误。您能否建议 wso2 入站端点连接器是否支持 2.3.1 版本的 kafka。谢谢。
以下是我收到的错误kafka.consumer.ConsumerTimeoutException cannot be found by synapse-core_2.1.7.wso2v133

猜你喜欢

2022-10-26
2016-06-02
2015-08-19
2020-02-25
1970-01-01
2017-12-07
2021-04-13
2018-10-24
2021-01-22

相关资源

下载 2022-12-21
下载 2022-12-31
下载 2023-04-11
下载 2021-06-26

最近更新更多

热门标签

Java Python linux javascript Mysql C# Docker 算法前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库数据结构大数据 js 机器学习微服务 Android Go 程序员面试 JVM ASP.net core 云原生人工智能后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习多线程 React 架构 devops 爬虫云计算 Spring Boot LeetCode