Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Kafka Connect Confluence S3 Sink 连接器:找不到类 io.confluence.connect.avro.AvroConverter
使用此 Kafka Connect 连接器 https www confluence io hub confluenceinc kafka connect s3 https www confluent io hub confluentinc
ApacheKafka
apachekafkaconnect
confluentplatform
使用表白名单选项更新 Debezium MySQL 连接器
我正在使用 Debezium 0 7 5 MySQL 连接器 并且我试图了解如果我想使用以下选项更新此配置 最好的方法是什么table whitelist 假设我创建了一个连接器 如下所示 curl i X POST H Accept ap
mysql
ApacheKafka
apachekafkaconnect
debezium
无法找到任何实现 Connector 且名称与 io.debezium.connector.mysql.MySqlConnector 匹配的类,可用的连接器有
使用 Kafka MySQL 和 Debezium 设置数据流管道 我是这个版本的 Kafka 3 4 0 MySQL 8 Debezium 2 2 1 Java 11 目标 我想从 MySQL 捕获所有 CDC 并将数据流式传输到 Kaf
ApacheKafka
apachekafkaconnect
debezium
调试自定义 Kafka 连接器的简单有效的方法是什么?
我正在使用几个 Kafka 连接器 在控制台输出中没有看到它们的创建 部署有任何错误 但是我没有得到我正在寻找的结果 没有任何结果 无论是期望的还是否则 我基于 Kafka 的示例 FileStream 连接器制作了这些连接器 因此我的调试
Java
debugging
ApacheKafka
slf4j
apachekafkaconnect
kafka 连接 s3 源无法与 Minio 一起使用
我已经验证了与 minio 的连接 确保凭据工作正常并且可以访问 minio 另外 如果我尝试任何其他值store url http minio 9000我无法保存配置 所以我猜想在可见性方面不存在问题卡夫卡连接容器和minio容器 我不确
amazons3
ApacheKafka
apachekafkaconnect
Minio
s3kafkaconnector
如何使用rest api设置kafka连接auto.offset.reset
我创建了一个接收器 kafka 连接 将数据转换为其他存储 我想设置auto offset reset as latest当新连接器创建时kafka connect rest api 我已经设定consumer auto offset re
ApacheKafka
apachekafkaconnect
Kafka JDBC Sink Connector 对于具有可选字段的模式的消息给出空指针异常
Kafka JDBC Sink Connector 对于具有可选字段 parentId 的模式的消息给出空指针异常 我错过了什么吗 我正在使用开箱即用的 JSONConverter 和 JDBC Sink Connector 关于 Kafk
json
JDBC
ApacheKafka
apachekafkaconnect
confluentplatform
如何复制或配置kafka connect插件文件?
我已经从以下位置下载了插件文件https www confluence io connector kafka connect cdc microsoft sql https www confluent io connector kafka
ApacheKafka
apachekafkaconnect
在 Confluence 4.1 + Kafka 1.1 中为 Kafka Connect 打包自定义 Java `partitioner.class` 插件?
我已经成功地将用 Java 编写的简单自定义 Partitioner 类用于 Confluence 3 2 x Kafka 0 10 x 上的 Kafka Connect 接收器 我想升级到 Confluence 4 1 Kafka 1 1
ApacheKafka
apachekafkaconnect
如何连接Kafka和Elasticsearch?
我是Kafka的新手 我使用kafka通过logstash收集netflow 可以 并且我想将数据从kafka发送到elasticsearch 但是存在一些问题 我的问题是如何将 Kafka 与 Elasticsearch 连接起来 net
elasticsearch
ApacheKafka
kafkaconsumerapi
apachekafkaconnect
Kafka 连接教程停止工作
我在此链接中执行了步骤 7 使用 Kafka Connect 导入 导出数据 http kafka apache org documentation html quickstart http kafka apache org documen
Kafka Connect 进入重新平衡循环
我刚刚部署了 Kafka Connect 我只使用连接源 MQTT 应用程序位于两个实例的集群上 2 个容器上 机器 现在它似乎进入了一种重新平衡循环 我一开始有一点数据 但没有新数据出现 这就是我在日志中得到的内容 2017 08 11
ApacheKafka
kafkaconsumerapi
apachekafkaconnect
Kafka Streams 在 HDFS 上查找数据
我正在使用 Kafka Streams v0 10 0 1 编写一个应用程序 并希望通过查找数据来丰富我正在处理的记录 该数据 带时间戳的文件 每天 或每天 2 3 次 写入 HDFS 目录 我怎样才能将其加载到Kafka Streams应
Kafka Consumer Group Id 和消费者重新平衡问题
我正在使用卡夫卡0 10 0和动物园管理员3 4 6在我的生产服务器中 我有 20 个主题 每个主题大约有 50 个分区 我总共有 100 个消费者 每个消费者订阅了不同的主题和分区 所有消费者都具有相同的 groupId 那么 如果针对特
ApacheKafka
kafkaconsumerapi
apachekafkaconnect
Kafka Connect - 删除带有配置的连接器?
我知道如何删除 Kafka 连接器 如此处所述Kafka Connect 如何删除连接器 https stackoverflow com questions 48947250 kafka connect how to delete a co
ApacheKafka
apachekafkaconnect
卡夫卡领导者选举什么时候发生?
Kafka High Level Producer 何时以及多久选举一次领导者 它是在发送每条消息之前执行还是仅在创建连接时执行一次 每个代理都有有关主题 和分区 及其领导者列表的信息 每当新领导者当选或分区数量发生变化时 动物园管理员都会
ApacheKafka
kafkaproducerapi
apachekafkaconnect
Kafka Connector 的任务列表为空
在卡夫卡启动后 有时我会出现这种行为 并非总是如此 似乎是随机的 org apache kafka connect runtime rest errors ConnectRestException Internal request miss
ApacheKafka
apachekafkaconnect
Kafka 连接:提供了配置 XXX,但不是 AdminClientConfig 中的已知配置
启动 Kafka Connect 时 我看到很多警告 10 33 56 706 DistributedHerder WARN org apache kafka clients admin AdminClientConfig The conf
ApacheKafka
apachekafkaconnect
Kafka s3 连接“值不是结构类型”错误
我使用以下参数加载 s3 连接器 confluent load s3 sink name s3 sink config connector class io confluent connect s3 S3SinkConnector task
ApacheKafka
apachekafkaconnect
confluentplatform
Kafka连接消费者引用偏移量并存储在消息中
如果我使用 kafka connect 来消费消息并存储到 s3 使用 kafka connect s3 连接器 我是否可以将消息偏移量与事件负载一起存储 我希望使用这些数据对消息进行一些排序 并检查是否存在任何间隙或检查我收到的消息中是否
ApacheKafka
apachekafkaconnect
1
2
3
4
»