apache-kafka - Kafka 与 Kafka Connect 术语 - Sources & Sinks 或 Producers & Consumers
问题描述
我正在阅读 Kafka 和 Kafka Connect。该文档在 Kafka Connect 文档中以一种通用的方式提到了“Kafka sources”和“Kafka sinks”。我不确定这两个术语是否特定于 Kafka Connect,或者它们只是指生产者和消费者。
解决方案
如果您需要将数据带入您的 kafka 集群或将数据复制到您的 kafka 之外(将数据从/复制到 kafka),有许多工具支持您完成该任务,
您不妨使用 Kafka Consumer / Producer API 编写和维护您的代码
为了避免为“已经解决的问题”创建新代码而苦苦挣扎,kafka 社区开发了 Kafka Connect 框架。
“kafka 方式”是利用其名为 kafka connect 的内部生态系统工具。kafka connect 是一个分布式框架,有许多社区或供应商支持的连接器。无论是开源的还是专有的,都有一个庞大且不断增长的中心“市场”可以满足任何需求。
连接器是在框架内运行的一段可插拔代码(JAR 文件),有两种类型的连接器,sink 连接器是“从 kafka 读取并接收到目标”,以及源连接器是“从数据源读取并写入 kafka ”。为了设置连接器,您只需设置一个包含所有必需参数的配置文件,而不需要任何编程技能。没有代码。为了简单而失去了一些灵活性
推荐阅读
- c - 当给定 3 的位掩码时,为什么 printf() 打印 21 而不是 11?
- javascript - 使用 javaScript 重新加载特定的文本框/选择选项
- python - 将空白视频添加到音频的 Python 脚本(多个)
- matlab - 使用值中的空格逐行导入 ASCII 制表符分隔
- django - Django-allauth 没有在自定义 SignupForm 上保存附加字段
- javascript - 我如何将身份验证错误从节点 js 发送到我的 html 客户端页面?
- delphi - 如何使用 ReadPrinter?
- excel - 我如何在 1 张表中搜索某些条件,然后将相邻单元格复制到表 2
- java - 文本外观,在 TextView 和 CardView 内
- python - 如何将python事件变量传递给另一个函数?