kafka-connect-archtype:Maven快速开始构建Kafka Connect连接器

preview
共35个文件
java：19个
xml：5个
properties：3个
Java
需积分: 9 0 下载量 200 浏览量 2021-05-24 04:20:50 上传 评论 收藏 30KB ZIP 举报
资源详情
资源评论
评论 收藏
行者无疆0622
  • 粉丝: 18
  • 资源: 4632
上传资源 快速赚钱
voice
center-task 前往需求广场，查看用户热搜

相关推荐

zip

kafka-connect-twitter：Kafka Connect连接器，用于从Twitter实时流数据

介绍 该连接器使用Twitter流API侦听状态更新消息，并将其即时转换为Kafka Connect结构。 目标是尽可能匹配Twitter状态对象。 组态 TwitterSourceConnector 这个Twitter Source连接器用于实时从Twitter提取数据。 name =connector1 tasks.max =1 connector.class =com.github.jc
zip

kafka-connect-twitter, Kafka 连接接收器/Twitter.zip

kafka-connect-twitter, Kafka 连接接收器/Twitter Kafka 连接 TwitterTwitter的Kafka 连接。 提供了源( 从 Twitter 到 Kafka ) 和接收器( 从 Kafka 到 Twitter ):接收接收来自 Kafka的普通字符串，这是使用 Tw
zip

crash-test-source-connector:崩溃控制的Kafka Connect连接器

崩溃测试连接器 崩溃控制的Kafka Connect连接器
zip

kafka-connect-elasticsearch-source:Kafka Connect Elasticsearch源

Kafka-connect-elasticsearch-source Kafka Connect Elasticsearch来源：从elastic-search获取数据并将其发送到kafka。 连接器仅使用严格的增量/时间字段（例如时间戳或增量ID）来获取新数据。 它支持动态模式和嵌套对象/数组。 要求： Elasticsearch 6.x和7.x Java> = 8 玛文 输出数据序列化
zip

kafka-connect-mongodb:用于Kafka Connect的MongoDB接收器连接器

kafka-连接-mongodb 您可以通过使用kafka9-connect-mongodb分支将此连接器用于Kafka9。 用于Kafka Connect的MongoDB接收器连接器提供了从Kafka主题或主题集到MongoDB集合或多个集合的简单，连续的链接。 连接器使用Kafka消息，重命名消息字段，选择特定的字段并将它们向上插入到MongoDB集合中。 连接器支持JSON和Avro
zip

kafka-connect-oss:Kafka Connect OSS连接器套件

Kafka Connect OSS 现在，您可以将此连接器用作接收器，以json，avro或parquet格式将数据从kafka主题上载到OSS。 该连接器定期轮询来自Kafka的数据，然后将其上传到OSS。 您可以配置一个分区程序以将数据拆分为多个块，每个数据块均表示为一个OSS对象。键名称对主题，Kafka分区和该数据块的起始偏移量进行编码。 如果在配置中未指定分区程序，则使用保留Kafk
zip

kafka-connect-hdfs:Kafka Connect HDFS连接器

Kafka Connect HDFS连接器 kafka-connect-hdfs是一个用于在Kafka和Hadoop HDFS之间复制数据。 可以在找到该连接器的文档。 发展 要构建开发版本，您需要Kafka的最新版本以及一系列上游Confluent项目，您必须从其相应的快照分支中进行构建。 有关此过程的指导，请参见。 您可以使用标准生命周期阶段在Maven中构建kafka-connect-h
zip

kafka-docker-playground-connect：使用vdesaboukafka-docker-playground存储库所需的Confluent Hub连接器创建Kafka Connect映像

kafka-docker-playground-connect 使用存储库所需的Confluent Hub连接器创建Kafka Connect映像 连接器 版本 confluentinc-connect-transforms 1.4.0 confluentinc-kafka-connecting-activemq 11.0.0 confluentinc-kafka-active-mq-s
zip

kafka-connect-mqtt:Kafka Connect MQTT连接器

kafka-connect-mqtt 此仓库包含用于Apache Kafka的MQTT源和接收器连接器。 已通过Kafka 2+进行了测试。 使用源连接器，您可以订阅MQTT主题，并将这些消息写到Kafka主题。 接收器连接器以相反的方式工作。 笔记： 目前不支持SSL连接 该连接器仅适用于单个任务。 设置maxTasks> 1无效。 建立连接器 要构建连接器，必须安装以下组件： Ja
zip

kafka-connect-jdbc:Kafka Connect连接器，用于兼容JDBC的数据库

Kafka Connect JDBC连接器 kafka-connect-jdbc是一个用于与任何兼容JDBC的数据库之间加载数据。 可以在找到该连接器的文档。发展要构建开发版本，您需要Kafka的最新版本以及一系列上游Confluent项目，您必须从其相应...
zip

kafka-connect-jdbc:修改kafka connect源码-修改

Kafka Connect JDBC连接器 kafka-connect-jdbc是一个用于向与JDBC兼容的数据库之间加载数据。 可以在找到该连接器的文档。 发展 要构建开发版本，您需要Kafka的最新版本。 您可以使用标准生命周期阶段在Maven中...
zip

kafka-connect-elasticsearch:Kafka Connect Elasticsearch连接器

Kafka Connect Elasticsearch连接器 kafka-connect-elasticsearch是一个用于在Kafka和Elasticsearch之间复制数据。发展要构建开发版本，您需要Kafka的最新版本。 您可以使用标准生命周期阶段，使用Maven构建kafka-...
zip

kafka-connect-storage-cloud：用于云存储的Kafka Connect连接器套件（Amazon S3）

适用于S3的Kafka Connect连接器 kafka-connect-storage-cloud是Confluent 的存储库，旨在将数据从Kafka复制到Amazon S3。适用于Amazon Simple Storage Service（S3）的Kafka Connect接收器连接器可以在找到该连接器...
zip

kafka-connect-spooldir：Kafka Connect连接器，用于将CSV文件读入Kafka

介绍 通过安装 该Kafka Connect连接器提供了监视目录的文件和在将新文件写入输入目录时读取数据的功能。 输入文件中的每个记录将根据用户提供的模式进行转换。 CSVRecordProcessor支持读取CSV或TSV文件。 它可以将CSV即时转换为强类型的Kafka Connect数据类型。 当前，它支持Kafka Connect支持的所有架构类型和逻辑类型。 如果将其与Confluen
zip

kafka-connect-rest:Kafka Connect REST连接器

Kafka Connect REST连接器 在Docker中构建和运行Spring示例 生成项目并将罐子复制到示例 mvn clean install && \ cd examples/spring/gs-rest-service && \ mvn clean install && \ cd .. && \ cp ../../kafka-connect-rest-plugin/target/ka
zip

kafka-connect-mongodb：**非官方社区** Kafka Connect MongoDB Sink连接器-在此处找到官方的MongoDB Kafka连接器：https：www.mongodb.comkafka-connector

Kafka Connect MongoDB 这是用于的基本 。 该连接器使用官方的MongoDB 。 将来的发行版可能还支持。 用户/感言 公司 “作为一家知名的大型德国零售商的子公司， Qudosoft面临的挑战是融合了创新和现有工作流程中的性能概念。 核心一种新颖的事件驱动架构，Kafka一直在自2016年起进行实验性使用，随后于2017年进行连接。 由于MongoDB是我们选择的数据库
zip

kafka-connect-storage-cloud:用于云存储的Kafka Connect连接器套件套件（当前包括Amazon S3）

Kafka Connect套件的云存储连接器 kafka-connect-storage-cloud是一套旨在用于在Kafka和公共云存储（例如Amazon S3）之间复制数据。 下面列出了当前可用的连接器： 适用于Amazon Simple Storage Service（S3）的Kafka Connect接收器连接器 可以在找到该连接器的文档。 发展 要构建开发版本，您需要Kafka的最新版
zip

springboot-kafka-connect-jdbc-streams：主要目标是使用Kafka Connect和Streams。 我们有store-api，可在MySQL中插入更新记录； 源连接器监视MySQL中插入的更新记录，并将与这些更改相关的消息推送到Kafka； 接收器连接器，用于从Kafka读取消息并在ES中插入文档； 在Kafka中侦听消息的存储流，使用Kafka Streams对待它们，然后将新消息推回Kafka

springboot-kafka-connect-jdbc-streams 该项目的主要目标是与 ， 和一起玩。 为此，我们具有：在中插入/更新记录的store-api ； Source Connectors ，用于监视MySQL插入/更新的记录，并将与这些更改相关的消息推送到Kafka ； Sink Connectors ，用于监听来自Kafka消息并在插入/更新文档； 最后， store-s
zip

kafka-connect-tools:Kafka Connect工具

/dependency >要求Java 1.8 Gradle5Kafka Connect CLI 这是周围的一个微小的命令行界面（CLI），用于管理连接器。 它以git之类的方式使用，其中第一个程序参数指示命令：它可以是[ps|get|rm|create|run|status|...
zip

kafka-connect-storage-common:针对分布式文件系统和云存储的连接器之间的共享软件

用于存储连接器的Kafka Connect通用模块 之间针对分布式文件系统和云存储的共享软件模块。发展要构建开发版本，您需要Kafka的最新版本。 您可以使用标准生命周期阶段在Maven中构建kafka-connect-storage-common 。...
zip

kafka-connect-asterisk:Kafka连接器能够从Asterisk PBX AMI检索数据

Kafka Connect星号连接器 卡夫卡-CONNECT-星号是源[卡夫卡接头]。（ ）我们可以从任何推送数据（CDR一起AgentEvents，呼叫事件）版本1.4和以上卡夫卡主题。发展要构建开发版本，您需要Kafka的最新版本以及一系列上游...
zip

confluent-kafka-ES-connector-example:这是一个示例项目，用于说明如何使用融合连接器连接Elasticsearch和Kafka

Kafka Connect Elasticsearch连接器kafka-connect-elasticsearch是一个用于在Kafka和Elasticsearch之间复制数据。发展要构建开发版本，您需要Kafka的最新版本。 您可以使用标准生命周期阶段，使用Maven构建kafka-...
zip

kafka-connect-common:整个datamountaineer kafka连接连接器使用的通用组件

Kafka Connect Common在Maven中，将其包含在您的连接器中。 发行版 版本 融合版本 卡夫卡 Kcql版本 Scala版本 2.0.5 5.4.0 2.4.0 2.8.7 2.12 2.0.4 5.4.0 2.4.0 2.8.7 2.12 2.0.3 5.4.0 2.4.0 2.8.6 ...
zip

kafka-connect-redis:f Kafka Connect Redis的源和接收器连接器

Kafka Connect Redis 用于Redis的Kafka源和接收器连接器 连接器 来源 Kafka Connect Redis Source使用Redis发布/订阅订阅Redis通道/模式（包括），并将接收到的消息写入Kafka。 有关更多信息，请参见。 下沉 Kafka Connect Redis Sink使用Redis命令格式（ SET ， GEOADD等）使用Kafka记录，并
zip

aiven-kafka-connect-jdbc：用于JDBC兼容数据库的Kafka Connect连接器（接收器和源）

Kafka Connect JDBC连接器 该存储库包括用于JDBC兼容数据库的Sink和Source 器。 该项目源自Confluent 。 该代码是在更改项目许可证之前创建的。 我们要感谢Confluent团队在开发连接器方面所付出的努力，并致力于继续保持该货叉得到良好维护并真正保持打开状态。 文献资料 源连接器文档可在找到。 接收器连接器文档可在找到。 贡献 执照 该项目已获得。 请参
zip

kafka-connect-file-pulse：:link:多功能的Kafka Connect连接器，可轻松将任何格式的任何文件解析，转换和流式传输到Apache Kafka

Kafka Connect文件脉冲 Connect FilePulse是多功能，可扩展且可靠的，可轻松将任何格式的任何文件解析，转换和流式传输到Apache Kafka:trade_mark:。 连接FilePulse * 动机 在组织中，经常通过使用各种格式（例如CSV，XML，JSON，Avro等）的文件从旧系统中导出，共享和集成数据。 对于通常会导致复杂且难以维护的数据集成混乱的企业而言，
zip

kafka-connect-kafka

Kafka Connect Kafka连接器kafka-connect-kafka是一个用于向和从Kafka加载数据。发展要构建开发版本，您需要Kafka的最新版本以及一系列上游Confluent项目，您必须从其相应的快照分支中进行构建。 有关此过程的指导。...
zip

kinesis-kafka-connector:kinesis-kafka-connector 是基于 Kafka Connect 的连接器，用于将消息发布到 Amazon Kinesis 流或 Amazon Kinesis Firehose

Kafka-Kinesis-Connector 是与一起使用的连接器，用于将消息从 Kafka 发布到或 。 Firehose 的 Kafka-Kinesis-Connector 用于将消息从 Kafka 发布到以下目的地之一： 、 或 ，进而通过现有的商业智能工具和仪表板...
zip

kcetcd:Kafka Connect的示例源连接器，从etcd提取数据

该项目的目标不是主要为提供可用于生产的连接器，而是作为一个完整而简单的Kafka Connect源连接器的示例，遵循最佳实践-例如支持多个任务-并提供服务。作为示例连接器，用于学习目的（例如，在连接器的实现和测试...