Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
使用 Kafka Connect 将架构和数据更改从 MySQL 流式传输到 MySQL
我们如何使用 Kafka 连接源连接器将架构和数据更改以及某种转换传输到另一个 MySQL 实例 如果我使用 Kafka 的 Python 库 confluence kafka 在加载到目标数据库之前消费和转换消息 是否有办法传播模式更改
ApacheKafka
apachekafkaconnect
如何让 Kafka Connect 均匀地平衡任务/连接器?
我尝试运行一个包含 5 个工作线程和 2 个接收器连接器的 Kafka Connect 分布式集群 一个连接器配置为 max tasks 实际任务设置为 5 另一个连接器配置为 6 个任务 如果我理解正确的话 这应该意味着需要分配给工作人员
ApacheKafka
apachekafkaconnect
卡夫卡连接|无法反序列化主题数据 |检索 id 的 Avro 键/值架构版本时出错 |未找到主题错误代码:40401
首先感谢 OneCricketeer 迄今为止的支持 到目前为止我已经尝试了很多配置 我不知道还能尝试什么 使用汇合connect standalone worker properties sink properties访问外部流 连接正在
ApacheKafka
Avro
apachekafkaconnect
confluentschemaregistry
无法在分布式模式下运行 Kafka Connect - 尝试创建/查找主题“connect-offsets”时出错
2017 08 31 10 15 20 715 WARN 配置 提供了 internal key converter 但不是已知的配置 org apache kafka clients admin AdminClientConfig 231
ApacheKafka
apachekafkaconnect
在 Debezium Mysql Connector 中将更多表列入白名单的有效方法
将新表列入 debezium mysql 连接器白名单是否遵循任何最佳实践 我们在 CDC 流程中使用 debezium mysql 连接器 并且出现了一个用例 将更多表列入连接器配置的白名单 以下是正在使用的 Debezium 的版本详细
mysql
apachekafkaconnect
mysqlconnector
debezium
在多个节点上运行kafka connect分布式模式
我正在测试一个卡夫卡连接器的弹性 我想在它运行时杀死一个工作人员 从而杀死连接器实例 最简单的方法可能是强制分布式模式在多个节点上运行 然后终止该节点上的工作进程 对吗 如何使 Kafka 将生成工作程序连接到不仅仅是其启动的节点上 这是在
ApacheKafka
apachekafkaconnect
Kafka 连接可以使用批量模式的自定义查询吗?
我正在尝试发送 7 天前的每行记录 这是我正在研究的配置 但它 即使查询在数据库服务器上生成记录也不起作用 connector class io confluent connect jdbc JdbcSourceConnector task
ApacheKafka
apachekafkaconnect
Debezium-不含连接器类型
我正在尝试使用 Debezium 连接到本地计算机上的 mysql 数据库 尝试使用以下命令调用kafka sudo kafka bin connect standalone shsh kafka config connect standa
ApacheKafka
apachekafkaconnect
debezium
Kafka 连接集群设置或启动连接工作线程
我正在通过 kafka connect 我正在尝试了解这些概念 假设我已经设置了 kafka 集群 节点 k1 k2 和 k3 并且它正在运行 现在我想在不同节点 例如 c1 和 c2 中以分布式模式运行 kafka 连接工作程序 几个问题
ApacheKafka
apachekafkaconnect
confluentplatform
如何更改“kafka connect”组件端口?
在端口 8083 上我正在运行 Influxdb 我什至可以打开 GUIhttp 本地主机 8083 http localhost 8083 现在来到kafka 这里我指的是按照https kafka apache org quicksta
apachekafkaconnect
具有 json 模式的 Kafka jdbc 接收器连接器无法正常工作
使用最新的 kafka 和 confluence jdbc 接收器连接器 发送一条非常简单的 Json 消息 schema type struct fields type int optional false field id type s
json
JDBC
ApacheKafka
apachekafkaconnect
Kafka Connect 无法通过 SSL 读取 Kafka 主题
在我们的 docker swarm 中运行 kafka connect 并使用以下 compose 文件 cp kafka connect node image confluentinc cp kafka connect 5 1 0 por
SSL
ApacheKafka
apachekafkaconnect
如何获取 Kafka Debezium MySQL 连接器的database.server.name?
EDITING问题 尝试配置 Debezium MySQL Kafka 连接器 以为例 https debezium io documentation reference stable connectors mysql html mysql
ApacheKafka
apachekafkaconnect
debezium
Kafka Confluence:JDBC 接收器连接器中的删除模式给出错误,并且无法在“pk.fields”中使用复合键
我有两个问题 1 我启用了delete enabled as true 但由于它需要pk mode被设置为record key我无法使用 MySQL 表的复合键 因为我可以在设置时使用pk mode as record value 我尝试在
ApacheKafka
apachekafkaconnect
使用带有 Helm 安装的 Kafka/Confluence 的连接器
我已经使用 Helm 图表在本地 Minikube 上安装了 Kafkahttps github com confluenceinc cp helm charts https github com confluentinc cp helm
mysql
Kubernetes
ApacheKafka
apachekafkaconnect
confluentplatform
Kafka Connect 不支持主题策略
Context 我编写了几个小代码卡夫卡连接 https docs confluent io current connect index html连接器 一个每秒生成随机数据 另一个将其记录在控制台中 它们集成了一个模式注册表 https
ApacheKafka
Avro
apachekafkaconnect
confluentschemaregistry
现有的 Kafka 主题镜像方法的主要区别是什么
Kafka MirrorMaker是一种将 Kafka 主题从源代理镜像到目标代理的基本方法 不幸的是 它不符合我的可配置要求 我的要求很简单 解决方案应该是JVM应用程序 如果目标主题不存在 则创建它 解决方案应该能够向目标主题名称添加前
ApacheKafka
apachekafkaconnect
Kafka-MongoDB Debezium 连接器:分布式模式
我正在研究 debezium mongodb 源连接器 我可以通过将 kafka bootstrap 服务器地址提供为远程计算机 部署在 Kubernetes 中 和远程 MongoDB url 来在本地计算机上以分布式模式运行连接器吗 我
ApacheKafka
apachekafkaconnect
debezium
mongodbkafkaconnector
错误由于错误而停止(org.apache.kafka.connect.cli.ConnectStandalone)java.lang.NoClassDefFoundError:io/debezium/util/IoUtil
我正在尝试将我的 SQL Server 数据库连接到 Windows 上的 kafka 我下载了 Debezium jar 文件 它们位于名为 debezium connector sqlserver 的文件夹中 如下所示 卡夫卡文件夹 h
Windows
ApacheKafka
apachekafkaconnect
debezium
在 KafkaConnect 中使用 Avro,无需 Confluence Schema 注册表
我们在当前的基础设施中设置了普通的 apache Kafka 并开始记录一些我们想要使用 Kafka Connect 处理的数据 目前 我们使用 Avro 作为消息格式 但我们的基础设施中没有架构注册表 将来 我们计划用 Confluenc
ApacheKafka
Avro
apachekafkaconnect
confluentschemaregistry
«
1
2
3
4
»