云消息队列 Kafka 版连接器的相关内容

[帮助文档] Kafka自定义连接器提供的可观测性能力及错误排查步骤

本文介绍Kafka自定义连接器提供的可观测性能力及错误排查步骤。

大佬们，我flink 采用 upsert-kafka作为连接器建表（t1），数据中具有相同更新时间的

大佬们，我flink 采用 upsert-kafka作为连接器建表（t1），数据中具有相同更新时间的多条数据，查询t1表，数据取的是哪条呢

消息队列Kafka入门课程

4 课时 |

3098 人已学 |

加入学习

分布式消息系统 Kafka 快速入门

24 课时 |

640 人已学 |

加入学习

请问kafka 连接器创建kafka source表时配置参数'topic-pattern'='(e

请问kafka 连接器创建kafka source表时配置参数'topic-pattern'='(empty)|(student)'，如果正则中的部分topic未创建，此时job运行后，后续创建的topic会被消费吗？或者有什么办法能在任务运行后，将后续创建的，同时能被正则匹配的topic，也被运行...

请问，我这边设置了upsert-kafka 连接器，，为啥读取出来的主键没有更新呢，偏移量还是增

请问，我这边设置了upsert-kafka 连接器，，为啥读取出来的主键没有更新呢，偏移量还是增长呢，读取的条数还是那么多？

【源码解读】Flink-Kafka连接器自定义序列器和分区器

@TOC开篇导语Flink将数据sink至Kafka的过程中，在初始化生产者对象FlinkKafkaProducer时通常会采用默认的分区器和序列化器，这样数据只会发送至指定Topic的某一个分区中。对于存在多分区的Topic我们一般要自定义分区器和序列化器，指定数据发送至不同分区的逻辑。此篇博客所...

kafka 连接器实现 Mysql 数据同步 Elasticsearch

为什么需要将 Mysql 数据同步到 ElasticsearchMysql 作为传统的关系型数据库，主要面向 OLTP，性能优异，支持事务，但是在一些全文检索，复杂查询上面并不快。Elasticsearch 底层基于 Lucense 实现，天然分布式，采用倒排索引存储数据，全文检索效率...

Kafka 连接器使用与开发

Kafka 连接器介绍Kafka 连接器通常用来构建数据管道，一般有两种使用场景：开始和结束的端点：例如，将 Kafka 中的数据导出到 HBase 数据库，或者把 Oracle 数据库中的数据导入 Kafka 中。数据传输的中间介质：例如，为了把海量的日志数据存储到 Elasticsearch 中...