Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Debezium 是否可以配置 table_name => kafka 主题映射?
我读了http debezium io docs connectors mysql 但我找不到任何关于是否可以配置 debezium 的信息 以便可以将 2 个 或更多 表的更改写入同一个 kafka 主题 在我看来 它总是 1 个表 gt
mysql
ApacheKafka
apachekafkaconnect
debezium
Kafka connect(单消息转换)行过滤
我读到了 kafka 0 10 2 1 中引入的 Kafka 连接转换https kafka apache org documentation connect transforms 我注意到所有转换都是基于列的转换 我有一个需要基于值的过滤
filter
ApacheKafka
apachekafkaconnect
Kafka 连接器和架构注册表 - 检索 Avro 架构时出错 - 未找到主题
我有一个主题 最终会有很多不同的模式 目前它只有一个 我已经通过 REST 创建了一个连接作业 如下所示 name com mycompany sinks GcsSinkConnector auth2 config connector cl
ApacheKafka
Avro
apachekafkaconnect
confluentschemaregistry
Kafka 到 hdfs3 接收器缺少所需配置“confluence.topic.bootstrap.servers”,该配置没有默认值
Status 我的HDFS是通过ambari HDP安装的 我目前正在尝试将 kafka 主题加载到 HDFS 接收器中 Kafka 和 HDFS 安装在同一台机器 x x x x 上 除了根据我的需要更改一些端口之外 我没有对默认设置进行
ApacheKafka
HDFS
apachekafkaconnect
confluentplatform
将连接器添加到 Kafka Connect
我正在使用 Confluence Kafka Docker 镜像 特别是使用这个 https github com confluenceinc cp docker images tree 4 0 x examples cp all in o
jar
ApacheKafka
apachekafkaconnect
如何使用 kafka 使用 python 连接 JDBC 接收器和源
我想从一个系统直播到另一个系统 我正在使用 kafka python 并且能够在本地进行直播 发现连接器可以处理多个设备 有人可以建议我一种使用连接器在 python 中实现它的方法吗 Kafka Connect 是一个 Java 框架 而
ApacheKafka
apachekafkaconnect
kafkapython
具有多个任务的分布式官方 Mongodb Kafka 源连接器无法正常工作
我正在我的 Windows 机器上运行 Apache Kafka 有两个 Kafka Connect Workers 端口 8083 8084 和一个具有三个分区的主题 一个复制 我的问题是 每当我关闭其中一个 Kafka Connect
重新启动集群时连接消费者作业被删除
我在更改与 kafka 相关的一些属性并重新启动集群时面临以下问题 In kafka Consumer there were 5 consumer jobs are running 如果我们进行一些重要的属性更改 并且在重新启动集群时 某些
ApacheKafka
apachekafkaconnect
Kafka Connect-在写入接收器之前修改记录
我已经使用 confluence 4 0 0 安装了 Kafka connect 使用 hdfs 连接器 我可以将从 Kafka 主题收到的 Avro 记录保存到配置单元 我想知道在写入hdfs接收器之前是否有任何方法可以修改记录 我的要求
Hadoop
ApacheKafka
apachekafkaconnect
如何转换和提取Kafka接收器JDBC连接器中的字段
我正在使用第 3 方 CDC 工具 将数据从源数据库复制到 Kafka 主题中 示例行如下所示 data USER ID string 1 USER CATEGORY string A beforeData Data USER ID str
ApacheKafka
apachekafkaconnect
Kafka JDBC Sink 连接器:未分配任务
我尝试使用以下配置启动 JDBC 接收器连接器 name crm data sink hh config connector class io confluent connect jdbc JdbcSinkConnector tasks m
ApacheKafka
apachekafkaconnect
我们可以在 mongodb 中更新/更新记录吗?数据源是kafka
我们可以更新 更新插入 mongodb 中的记录 但是是否有任何方法或函数可以让我们直接在 mongodb 中更新或更新插入文档 并且源系统是 kafka 目标系统是 mongodb 是的 我们可以更新 更新插入数据 要更新 您必须在 Ka
ApacheKafka
apachekafkaconnect
mongodbkafkaconnector
Kafka Connect 接收器任务忽略容差限制
我尝试忽略接收器连接器中的错误消息errors tolerance all选项 完整的连接器配置 name crm data sink pandora config connector class io confluent connect
ApacheKafka
apachekafkaconnect
Debezium:数据库中没有记录最大LSN;请确保 SQL Server 代理正在运行
这个问题与 Debezium 如何使用 Kafka Connect 正确注册 SqlServer 连接器 连接被拒绝 在 Windows 10 中 我在 Docker 容器外部的 Microsoft SQL Server 实例上运行 Deb
sqlserver
ApacheKafka
apachekafkaconnect
debezium
使用Kafka Connect时如何转换所有时间戳字段?
我正在尝试将所有时间戳字段转换为格式为字符串类型yyyy MM dd HH mm ss 要转换多个字段 我必须为每个字段单独创建一个转换 transforms tsFormat1 tsFormat2 tsFormatN transforms
ApacheKafka
apachekafkaconnect
Kafka Connect 启动失败
我在新的linux centos 7上安装了kafka confluence oss 4 0 但kafka连接无法启动 重现步骤 Install Oracle JDK 8 Copy confluent 4 0 0 folder on opt
ApacheKafka
apachekafkaconnect
confluentplatform
«
1
2
3
4