Kafka Connect。如何处理自定义对象列表，指定模式和构建sourcerecord值
我有DTO Cryptonews。其中包含 List currencies 我想将“货币” 字段保存到 sourcerecord 时。 无法弄清楚如何： 在模式中声明它。 建筑价值时将其传…
KAFKA JMS源连接器将消息写入更多主题
我有一个ActiveMQ Artemis JMS队列，并且有一个Kafka源连接器。我想将来自此队列的消息写成 + + 主题并行。我发现简单的消息变换可能是解决方案。我尝…
Debezium Connector启动，但无法从CDC返回表
我正在使用SQL Server连接器，日志显示锁定捕获的表[] - 未捕获表。我已经验证了模式，表格和数据库。我已经尝试了以下所有内容，所有这些主题已预先…
Kafka Microsoftsqlserversource connect-主题中的重复条目
我们需要设置Kafka Microsoftsqlserverserce Connect。 这是为了捕获在Azure SQL数据库中的一个销售表中执行的所有交易（插入/更新）。 为了带来对上…
基于事实的Ansible循环以重新启动Kafka连接器失败任务
在这里，我想重新启动KAFKA连接任务，如果使用Ansible-PlayBook处于失败状态，我已经使用'set_fact'来获取连接器任务状态 我想对收集的事实创建一个循…
Debezium SQLServer源未读取数据
我有一个运行的Kafka Connect实例，并在本文底部提交了以下配置。 问题 database.server.name = connect_test ，并为我想摄入kafka的每个表创建主题。…
Kafka Connect-由于意外对象类型而没有存在转换器：java.lang.double
我有一个Kafka流应用程序，该应用程序根据主题的值，唱歌窗口进行一些计算。我读到，持续数据的最佳实践是将值推向另一个主题，并使用Kafka Connect从…
Kafka连接器无法连接AWS MSK
我正在尝试配置AWS中的MSK Connect，以下是配置。 INFO [AdminClient clientId=adminclient-1] Metadata update failed (org.apache.kafka.clients.ad…
Debezium连接器如何处理错误？
我计划使用MySQL Debezium连接器，并在配置上有一个疑问以进行错误处理。 Apache Kafka Connect似乎具有 errors.tolerance 用于错误处理的属性。它在 …
与AWS Document DocumeDB一起使用Kafka Connect
我正在尝试将AWS DocumentDB用作存储从Kafka收到的数据的水槽，并且想知道MongoDB Kafka连接器是否与DocumentDB一起使用，因为其文档提到它与MongoDB…
MirrorSourCeconnector：覆盖消费者钥匙。Serializer属性
我正在尝试从集群A到集群B中的主题运行MirrorSourCeconnector。 创建连接器并消耗第一条消息后，我注意到镜像主题密钥和值总是被序列化为ytearray。在…
有没有一种方法可以使用JDBC接收器连接器使用出口字段值进行更新？
我想实现页面视图计数。每次访问该页面时，将发布一个事件给Kafka。该事件包括pageID和日期。 我想使用JDBC连接器来增加页面计数与页面和日期相对。 J…
kafka Connect Confluent S3水槽连接器：io.confluent.connect.avro.avroconverter无法找到
使用此kafka连接器： 我将其手动安装到我的kafka connect docker image的/opt/opt/kafka/plugins 。 我的目的是使用Kafka Connect将AVRO记录从Kafka主…
使用Kafka Connect流出从MySQL到MySQL的模式和数据更改
我们如何使用Kafka Connect Countare Connector将模式和数据以及某种转换以及某种转换一起变化为另一个MySQL实例。 如果我使用Kafka的Python库（Confl…
