Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
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
Kafka JDBC 连接器中的自定义分区分配
我有一个用例 我需要编写自定义逻辑来根据消息中的某些关键参数分配分区 我对此做了一些研究 发现卡夫卡转换支持覆盖转换接口中的某些方法 但我无法在 git hub 或其他地方执行一些示例代码 有人可以分享示例代码或 git hub 链接来在
Java
ApacheKafka
apachekafkaconnect
使用 Kafka Connect 将架构和数据更改从 MySQL 流式传输到 MySQL
我们如何使用 Kafka 连接源连接器将架构和数据更改以及某种转换传输到另一个 MySQL 实例 如果我使用 Kafka 的 Python 库 confluence kafka 在加载到目标数据库之前消费和转换消息 是否有办法传播模式更改
ApacheKafka
apachekafkaconnect
如何让 Kafka Connect 均匀地平衡任务/连接器?
我尝试运行一个包含 5 个工作线程和 2 个接收器连接器的 Kafka Connect 分布式集群 一个连接器配置为 max tasks 实际任务设置为 5 另一个连接器配置为 6 个任务 如果我理解正确的话 这应该意味着需要分配给工作人员
ApacheKafka
apachekafkaconnect
卡夫卡连接|无法反序列化主题数据 |检索 id 的 Avro 键/值架构版本时出错 |未找到主题错误代码:40401
首先感谢 OneCricketeer 迄今为止的支持 到目前为止我已经尝试了很多配置 我不知道还能尝试什么 使用汇合connect standalone worker properties sink properties访问外部流 连接正在
ApacheKafka
Avro
apachekafkaconnect
confluentschemaregistry
无法在分布式模式下运行 Kafka Connect - 尝试创建/查找主题“connect-offsets”时出错
2017 08 31 10 15 20 715 WARN 配置 提供了 internal key converter 但不是已知的配置 org apache kafka clients admin AdminClientConfig 231
ApacheKafka
apachekafkaconnect
在 Debezium Mysql Connector 中将更多表列入白名单的有效方法
将新表列入 debezium mysql 连接器白名单是否遵循任何最佳实践 我们在 CDC 流程中使用 debezium mysql 连接器 并且出现了一个用例 将更多表列入连接器配置的白名单 以下是正在使用的 Debezium 的版本详细
mysql
apachekafkaconnect
mysqlconnector
debezium
1
2
3
4
»