apache-kafka-connect
-
使用 Avro 从 Logastash 发送到 Kafka
-
Kafka 连接自定义转换：重写 apply() 方法似乎没有效果，但重写键和值中的 newRecord 方法有效
-
Kafka Connect JDBC Sink Connector 给 WorkerSinkTask ERROR
-
将消息从 Kafka 转发到 Elasticsearch 和 Postgresql
-
Kafka 代理关闭，因为日志目录失败
-
Kafka S3 Connector Once Delivery Guarantee 如何工作
-
使用 Kafka Connect S3 Sink 时从 S3 路径中删除主题名称
-
`delete.enabled=true` 不通过 JDBC 接收器连接器删除 MySQL 中的记录
-
如何将没有模式的数据发送到 kafka - 汇合 jdbc - 接收器使用情况？
-
如何部署具有多个主题和 table 目的地的 kafka 接收器连接
-
什么是数据类型 LOB 的列不能是唯一的或主键错误？
-
我可以在 kafka 主题上定义模式吗？
-
Kafka Producer 无法在没有 PK 和 return InvalidRecordException 的情况下验证记录
-
为什么无法使用 Kafka Connect 中的 JDBC Sink Connector 删除记录
-
Kafka Connect - Caused by: org.apache.kafka.connect.errors.ConnectException: table 的 PK 模式是 RECORD_KEY，但缺少记录密钥架构
-
如何将记录拆分为不同的流，从一个主题到不同的流？
-
kafka_Mongodb sync connector failing ERROR WorkerSinkTask{id=mongo-sink-0} 任务正在被终止并且在手动重新启动之前不会恢复
-
uk.co.threefi.kafka-connect-http是否支持SSL连接
-
Debezium：数据库中没有记录最大LSN；请确保 SQL 服务器代理是 运行
-
为什么我的 Kafka connect sink 集群只有一个 worker 处理消息？