s3-kafka-connector
-
跨两个不同的 kafka 连接集群的相同消费者组(s3 接收器连接器)
-
为 s3 kafka connect sink 实现自定义分区
-
Confluent Kafka S3 sink connector throws `java.lang.NoClassDefFoundError: com/google/common/base/Preconditions` when using Parquet format
-
汇合的 s3 源连接器如何知道它已经摄取了哪些文件以及哪些是新文件?
-
无法在kafka connect中使用接收器连接器
-
为什么我的 Kafka S3 连接器接收器在创建后删除我的主题(Kafka 连接器重新启动)?
-
S3 Kafka 接收器连接器中有没有办法确保所有记录都被消耗
-
ClassNotFound 异常 运行 Kafka Connect S3 源连接器
-
定义 Camel S3 源连接器时出错
-
Kafka Sink 连接器是否可以将记录时间戳作为存储在存储中的有效载荷包含在内
-
Spark 无法读取由 AvroParquetWriter 编写的 Parquet 文件中的 DECIMAL 列