Atlas-Kafka连接器

Atlas Hook for Kafka 2.1.0，已基于 CDH6.3.1 编译。

mysql-connector-java-5.1.6.jar 可用于 Java 应用程序连接到 MySQL 数据库。

Apache Kafka 连接器 Java 存档文件

此文件用于将MyEclipse连接到MySQL数据库。

JDBC 源和接收连接器能你在关系型数据库和 Kafka 之间交换数据。JDBC 源连接器可以轻松地把任何使用 JDBC 驱动的关系型数据库中的数据导入到 Kafka 主题中。举个例子，如果你有一个 MySQL 数据库，想把其中的数据实时推送到 Kafka 中，JDBC 源连接器就能帮你搞定。这个工具挺适合需要实现数据库与 Kafka 之间高效数据流通的场景。如果你是开发者，想要快速集成数据库和 Kafka，可以考虑使用这个连接器。其实它的配置也不复杂，直接按照文档配置好连接参数，数据就能源源不断地流入 Kafka 了。不过要注意，使用时要确认你的数据库支持 JDBC 驱动。否则，你需要额外安

所有经 NAMA 认证的供应商提供的连接器组件必须相互兼容，并满足或超过以下最低性能要求： 4.3.1 材料 4.3.1.1 端子: 磷青铜 4.3.1.2 电镀: 锡或锡/铅 4.3.1.3 外壳: UL 94V-2 尼龙 4.3.2 性能指标 4.3.2.1 额定电压 (最大值): 600V 交流电 4.3.2.2 最大额定电流 (六路): 7 安培 4.3.2.3 环境温度范围 (包括端子温升): -40℃ 至 +105℃ 任何关于配合、形式或功能的更改都需要得到 NAMA 的批准。单个组件，例如触点，不需要在不同供应商的产品之间互换。 更多详细信息请参考 4.3.6 节。

MySQL提供了基于标准的JDBC、ODBC和.Net驱动程序，使开发人员能够选择他们喜欢的编程语言来构建数据库应用程序。此外，一个本地的C库允许开发人员将MySQL直接嵌入到他们的应用程序中。

在用 PySpark 实时数据流时，连接 Kafka 几乎是必不可少的。你需要的这个spark-streaming-kafka-0-8-assembly_2.11-2.4.3.jar，就是用来实现这个功能的 JAR 包。只要将它放到 Python 所在的 site-package 目录下，并确保它被添加到 Pyspark 的 jars 目录里，你就可以轻松地在 PySpark 中读取 Kafka 的消息了。连接简单，性能也还不错，是多项目中不可或缺的部分。如果你在搞流式数据，这就是你需要的工具包！

Apache Flink Kafka SQL连接器flink-sql-connector-kafka_2.12-1.13.1.jar是用于在Flink SQL环境中与Apache Kafka集成的JAR包。版本中的2.12和1.13.1分别对应Scala和Flink的版本。该连接器支持Flink SQL的标准DDL和DML操作，可用于从Kafka读取数据或向Kafka写入数据。