在同一kafka群集中使用kafka连接复制器
我考虑使用Kafka Connect Replicator进行同一集群中的事件富集。 这个想法是要拥有将丰富事件的SMT，之后需要将事件发送给Mongo db＆amp; S3桶。 我知…
创建弹性水槽连接器时序列化错误
在创建弹性水槽连接器时，我遇到了以下错误。 CREATE SOURCE CONNECTOR `testconnector` WITH( "type.name"= '_doc', "input.data.format"= 'AVRO', "…
strimzi将容器加载到AWS ECR-错误检查推动权限
我正在通过Strimzi操作员在Kubernetes上运行Apache Kafka。 我正在尝试安装使用MySQL Debezium连接器的Kafka连接。 这是连接器配置文件： apiVersion:…
Confluent JDBC接收器连接器可以识别Debezium Connector捕获的记录
我尝试使用Kafka Echo系统来cdc Postgresql。 Debezium Connector捕获PostgreSQL 13数据，然后生产到Kafka。而且我将Confluent的JDBC接收器连接器连接…
通过雪花kafka连接器无法将数据插入到雪花数据库中，但是连接器已开始
Kafka,Zookeeper user@ip-XX-XX-XX-XXX config]$ curl -X POST -H "Content-Type: application/json" --data @snowflake-connector.json http://XX.XX…
Kafka到Elasticsearch连接器无法启动
Elasticsearch - ＆gt; Elasticsearch-7.6.0 我试图通过使用Elasticsearch Sink Connector将数据从Kafka主题转移到Elasticsearch。 但是启动连接器以…
如何将预先创建的Kafka主题配置为Kafka-Connect中的水槽？
我试图沉没一个postgreql db（源）事件将记录到已经创建和配置的主题的Kafka Confluent Cloud。 仅供参考，我正在使用 quay.io/debezium/connect:1.9 …
Kafka-connect-fs使用密钥文件或无密码条目连接SFTP
我正在尝试集成Kafka Connect FS＆amp;源SFTP带有用户名＆amp;无密码条目（私钥）。但是我会在下面的设置中遇到验证失败。 它与用户名：password@host…
使用Apache Kafka＆amp;构建实时数据仓库mysql
我们在MySQL上有一个数据仓库，其中包括尺寸，事实表和一些汇总表。 我想使用Apache Kafka实现相同的结构，其中源将是另一台MySQL Server。我想解决以…
将退出主题用于多个连接器是一个好习惯吗？
我正在使用Debezium Postgresql连接器将用户表进入Kafka主题。 我有一个JDBC接收器连接器连接器，然后将其从主题中读取数据并将其推入自己的数据库。 …
kafka雪花连接器 - 连接器错误后停止
我一直在检查所有Kafka雪花连接器帖子，但他们都没有谈论我遇到的问题。 我和Zookeper一起在本地安装了Kafka，也想运行一个雪花连接器，将数据从Kafka…
如何指定连接器是源还是水槽？
我目前正在配置kafka connect（带有 debezium/connect docker docker image ），我成功连接它使用环境变量到KAFKA： docker run -it --rm --name AAAA…
KAFKA连接连接器将连接器限制为每个主题的一个接收器任务
我正在使用我自己的自定义水槽插件运行一个Kafka Connect Cluster（本地使用1个Worker Docker组成）。我有几个要在连接器中消耗的主题： topica，topi…
在Docker Redhat/kafka-connect容器中安装Cosmos DB模拟器SSL证书
我在本地计算机上进行了cosmos db仿真器的设置，然后从以下参数开始： /port=443 /AllowNetworkAccess /Key= 目前，它可以通过 https：//＆lt; localm…
