【问题标题】:Apache Strimzi Kafka Bridge implementationApache Strimzi Kafka 桥实现
【发布时间】:2020-01-31 07:39:18
【问题描述】:

对于社区来说,这是一个非常普遍的问题,尤其是 Kafka Strimzi Bridge 的人们,如果他们正在阅读这篇文章的话。

我正在尝试将他们的 Apache Kafka HTTP Bridge 实现为 POC。文档非常差,没有提供任何帮助。我真的只需要知道您如何使用桥接器发布和使用来自 Kafka 主题的消息。我已经开始搭建桥梁,但由于文档缺少基本示例,因此不知道其他任何内容。

【问题讨论】:

标签: apache-kafka strimzi


【解决方案1】:

您使用的是哪个版本的网桥? 有关公开 API 的桥接文档位于以下链接中以获取最新的 0.14.0 版本: https://strimzi.io/docs/bridge/latest/

您还可以在此处的 Strimzi 文档中找到对桥梁本身的总体描述和快速入门指南: https://strimzi.io/docs/latest/#kafka-bridge-concepts-str

您是在 Kubernetes 上使用它来部署 Apache Kafka 集群和 Strimzi 集群操作员,还是单独使用它?

如果您需要更多帮助,当然可以在 CNCF Slack 工作区加入我们的#strimzi 频道。

【讨论】:

  • 感谢您的回复。一段时间以来,我一直是 Slack 工作区的成员。我没有看到那里有任何成员问这个问题。我在 EC2 实例上部署它。我真正需要的只是一个使用网桥的简单示例。我尝试了多种在应用程序属性文件的 HTTP 端口上使用 curl 发布消息的方法。服务器似乎没有承认任何。整个文档都基于 Kubernetes。
  • 你能提供更多细节吗?端口是否可以从外部访问,那么您至少可以建立 TCP 连接吗?您是否尝试到达 /topics/{topicname} 端点进行发布?您是否从桥接器得到任何响应,日志中的某些内容? “服务器似乎不承认任何”是什么意思。 Kafka 集群在哪里运行?您提到了 Kubernetes,您是否也将它与 Strimzi 集群操作员一起用于部署 Kafka 集群?您能否提供您用于发布的示例?
  • 对不起,难以捉摸。我是用手机回复的。这是我的问题。
  • 抱歉,尼克,问题出在哪里?我什么都看不到:-)
  • 这是我的问题。 1)我启动了桥。我称之为提供服务的服务器。 2) 我可以使用 POSTMAN 或 curl 通常使用 /GET Api 并从服务器获得响应 3) 我无法使用 POST /topics/ 发布有关该主题的消息。我正在使用普通的旧卡夫卡。我能够直接运行 Kafka 生产者和消费者,它们可以使用确认 Kafka 设置正确的消息。 4)我只需要一个小的有效负载(任何有效负载)或者更确切地说是发布消息的格式。这个桥可以用于流式传输还是用作简单的请求/响应服务?。
猜你喜欢
  • 2020-06-19
  • 1970-01-01
  • 2020-04-24
  • 2016-12-11
  • 2019-10-04
  • 2021-10-27
  • 2021-09-28
  • 2022-01-20
  • 2021-03-03
相关资源
最近更新 更多