时间戳

首页 > 解决方案 > 没有 Sink 的 Kafka 流

apache-kafka - 没有 Sink 的 Kafka 流

问题描述

我目前正在为从 Kafka 主题读取数据并经过一些转换将数据放入 RabbitMq 的应用程序规划架构。我对 Kafka Streams 很陌生，它们看起来是我任务的不错选择。但问题是 Kafka 服务器托管在另一个供应商的位置，所以我什至无法将 Cafka 连接器安装到 RabbitMq Sink 插件。

是否可以编写没有任何 Sink 点但只处理输入流的 Kafka steam 应用程序？我可以在 foreach 操作中推送到 RabbitMQ，但我不确定 Stream 是否可以在没有汇点的情况下工作。

标签： apache-kafkarabbitmqapache-kafka-streams

解决方案

foreach是 Sink 动作，所以直接回答你的问题，不。

但是，Kafka Streams 应该仅限于 Kafka 通信。

Kafka Connect 可以在任何地方安装和运行，如果这是您想要使用的...您还可以使用其他 Apache 工具，如 Camel、Spark、NiFi、Flink 等，在从 Kafka 消费后写入 RabbitMQ，或编写任何应用程序使用您选择的语言。例如，Spring Integration 或 Cloud Streams 框架允许在许多通信渠道之间建立一个合同

推荐阅读