Apache Kafka Connect是Apache Kafka与其他数据系统之间可扩展且可靠的流数据的工具。 - https://kafka.apache.org/documentation.html#connect
我将 Kafka 与 Strimzi 运算符一起使用，我想知道是否应该创建最佳数量的 kafka 连接集群。我有一个中型基础设施，包含大约 50 个不同的业务日志......
MSK 连接器无法使用 KRaft 模式在 MSK 集群中找到类
我有一个使用 ZooKeeper 模式的 Kafka 3.7.x 集群，效果很好。现在我正在 KRaft 模式下尝试新的 Kafak： 但是，对于这个 KRaft 模式的 Kafka 集群，相同的连接器无法启动。 她...
KSQLDB 的 SQL 连接器，如何在 docker.yml 中实现？
我发现自己正在努力获取有关如何将 SQL Server DB 放入 KSQLDB 的文档更新？ 我想知道连接 Azure SQL Server 和 K 的最简单方法是什么...
我正在使用一个 Spring Boot Java 项目，其中我提到了一个消费者组，并且刚刚创建了一个消费者实例。这意味着如果我从这个消费者那里轮询数据，它应该默认重新...
如何使用 docker compose 在合流连接中添加多个连接器？
我正在尝试通过以下 docker-compose 在我的合流连接中添加 mongoDB 连接器和 mqtt 连接器： --- 版本：'2' 服务： 动物园管理员： 图片：confluenceinc/cp-zookeepe...
ksql 看不到先前安装的 datagen 连接器并且位于组件目录中
我正在浏览 Confluence 的使用 ksqlDB 的 Clickstream 数据分析管道教程。在我的 Mac 和基于 Ubuntu 的 VPS 上尝试过此操作 当我跑步时 运行脚本'/scripts/create-connectors.sql';
Ansible EDA Kafka 连接错误 - 尝试在规则手册中创建与 kafka 的连接，但规则手册激活失败
我一直在尝试在规则手册中创建与 kafka 的连接，但是当我运行规则手册激活时，我遇到此错误： ansible_rulebook.rule_set_runner - 信息 - 规则集：监听 eve...
为什么 Debezium Connector 无法连接到 SASL 激活的代理？
我正在尝试为我的 Kafka 系统启用 SASL/PLAIN。它实际上有效，我已经针对架构注册表和 Java 生产者测试了它。问题是 Kafka Connect 在 SASL 时无法建立连接...
DataStax Cassandra Sink Connector - 根据条件从 Kafka 主题提取数据
我正在尝试将数据从 Kafka 主题实时提取到 Cassandra 表。为此，我使用 DataStax Cassandra Sink 连接器。主题中事件的格式将为 JSON。我可以
我正在尝试创建一个使用protobuf值转换器的kafka接收器连接器。我有一个使用 JSON 的配置版本，但是我现在需要将其更改为使用 protobuf 消息...
MSK 连接器使用 Kafka SSL 或 SASL 身份验证与第三方托管集群握手
我创建了一个 kinesis 源连接器，它应该从 kinesis 流中提取数据并将相同的数据推送到 kafka 主题。 这里的用例是将连接器部署在 Amazon MSK 上
Caddy TLS 在 Kafka Connect UI 中不起作用
我使用此文档在 Kafka Connect UI 中配置 TLS/SSL： https://hub.docker.com/r/landoop/kafka-connect-ui/ 但没有写任何有关 TLS/SSL 的内容。后来我找到了凯迪
美好的一天， 基于https://docs.confluence.io/kafka-connect-jdbc/current/index.html#installing-jdbc-drivers， 我使用以下命令来安装 jdbc 连接器： confluence-hub 安装 confluen...
我正在尝试压缩我的 Kafka 主题，但在进行新修改后我仍然会得到相同密钥的重复，因此压缩不起作用。这是我正在使用的连接器。 我还配置了Kafka
kafka 可以连接 - mongo 源作为集群运行（max.tasks > 1）
我正在使用kafka-connect支持的以下mongo源。 我发现 mongo 源的配置之一（来自此处）是tasks.max。 这意味着我可以提供连接器
我有一个 Kafka Connect Sink，将记录从 Kafka 主题写入 S3。它正在工作，但速度太慢。 Kafka 主题每秒接收约 30k 条消息。 Connect Sink 无法跟上。我已经尝试过...
schemas.enable=false 配置未应用于连接器
我正在使用从kafka到mongo的mongokafka接收器连接器，连接器jar是mongo-kafka-connect-1.7.0-all.jar。我还在连接集群的插件路径中添加了 mongodb-driver-core-4.5.0.jar 。 ...
如何保证消息从一个Kafka Connect集群传输到另一个Kafka集群？
我们有一个 Kafka Connect 集群，运行多个插件和连接器。其中之一是 Debezium Connector fo Postgres v2.5，它从数据库中的表中获取行并将它们写入 kafka top...
连接超时：无法将 mongo 与 debezium 连接到 CDC
我在 docker-compose 中设置了 mongo 和 kafka 连接。我想使用 debezium 从 mongo 启用 CDC。这些是我的服务： 蒙戈数据库： 图片：蒙戈 重新启动：始终 容器名称：莫...
Debezium-Oracle-Connector：异常：无法解析 Oracle 数据库版本
配置： Oracle for windows 本地安装 通过 docker 运行 Kafka Connect 连接： 图片：debezium/connect-with-oracle-jdbc:2.6 oracle kafka 连接配置： { &q...