Apache Kafka Connect是Apache Kafka与其他数据系统之间可扩展且可靠的流数据的工具。 - https://kafka.apache.org/documentation.html#connect
如何在Kafka Source Connector中创建多个任务？
我是Apache Kafka的新手，我正在尝试创建多个任务，每个任务都有一个单独的目的。但源连接器方法taskClass（）仅返回1个任务类。那么我该如何创造更多？
如何将Confluent Control Center Interceptor添加到现有S3（Sink）连接器？监视接收器。我正在寻找文件。任何帮助表示赞赏。
使用最新的kafka和汇合的jdbc接收器连接器。发送一个非常简单的Json消息：{“schema”：{“type”：“struct”，“fields”：[{“type”：“...
Postgres使用JDBC Kafka Connect进行流式传输
我正在尝试使用Kafka Connect JDBC Connector在Postgres数据库中传输更改。我在启动时遇到问题，因为数据库非常大，查询每次都作为行终止...
使用JsonConverter的Kafka Connect HDFS Sink for JSON格式
通过JSON向Kafka制作/消费。使用以下属性保存到JSON中的HDFS：key.converter = org.apache.kafka.connect.json.JsonConverter value.converter = org.apache.kafka.connect.json ....
我启动了kafka连接图像。我配置了近25个运行源和接收器连接器，当我放入这个容器时，我只看到1个java进程root @ connect：/＃ps -ef | grep java root ...
kafka connect - 审计 - 在任务完成时触发事件
我们正在使用kafka构建一个异常管理工具。将有源连接器 - 它将从物理文件中提取记录。另一方面，将有接收连接（mongodb-sinkconnect）...
对于Kafka Connect Connector或Connector任务失败或遇到错误的情况，是否有任何警报选项？我们有Kafka Connect运行，它运行良好，但我们有错误......
通过apache官方页面https://kafka.apache.org/quickstart创建一个文本文件作为echo -e“foo \ nbar”> test.txt并使用kakfa connect以下命令使用bin / ...
我正在尝试使用kafka-jdbc-connector（源和接收器）和一个非常古老的数据库（cloudscape）。我有这个数据库的JDBC驱动程序。我把驱动程序放在“/ share / java / kafka / connect / jdbc”中......
Kafka SMT ValueToKey - 如何使用多个值作为关键？
我正在使用Confluent JDBCSourceConnector从Oracle表中读取。我正在尝试使用SMT生成由3个连接字段组成的密钥。 transforms = createKey transforms.createKey.type = ...
我有一个Kafka Connect源和接收器连接器，用于将数据放入Kafka并将其取出。我使用docker-compose运行Kafka和Kafka Connect，它以分布式模式运行connect。 ...
我使用基于JBoss的保险库来保护敏感数据，例如数据库凭证。我使用基于Java的HTTP REST客户端来创建分布式Kafka连接器，但最终得到了一个安全性......