6月15日，由中国信通院主办的以 “原生聚力，云数赋能”为主题的“2022云原生产业大会”在北京举行。凭借创新技术和领先实践，腾讯云云巢荣获“云原生技术创新案例”奖。腾讯云云巢是腾讯云自主研发的一站式云原生有状态服...

Apache Kafka是一款开源的消息引擎系统，也是一个分布式流处理平台。除此之外，Kafka还能够被用作分布式存储系统（极少）。

上一篇文章介绍了 Flink Data Sink，也介绍了 Flink 自带的 Sink，那么如何自定义自己的 Sink 呢？这篇文章将写一个 demo 教大家将从 Kafka Source 的数据 Sink 到 MySQL 中去。...

通过Flink官网可以看到Flink里面就默认支持了不少sink，比如也支持Kafka sink connector（FlinkKafkaProducer），那么这篇文章我们就来看看如何将数据写入到Kafka。...

Kafka的Producer发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程——main线程和Sender线程，以及一个线程共享变量——RecordAccumulator。main线程将消息发送给RecordAccumulator，Sender线程不断...

如上图，Source 就是数据的来源，中间的 Compute 其实就是 Flink 干的事情，可以做一系列的操作，操作完后就把计算后的数据结果 Sink 到某个地方。（可以是 MySQL、ElasticSearch、Kafka、Cassandra 等）。这里我说下自己目前做...

导语由中国信息通信研究院举办的首届“精益软件工程大会”已于今日6月16日开幕。关于精益软件工程大会云赋新生，精益求精随着云计算的蓬勃发展以及数字化转型的推进，各行业头部企业都已经开始云上软件开发实践，并形成了...

管道是一种特殊的文件，它不属于某一种文件系统，而是一种独立的文件系统，是只存在于内存中的文件，本质是内核的一块缓冲。写入的内容每次都添加在管道缓冲区的末尾，并且每次都是从缓冲区的头部读出数据。管道是单向的、先进...

kafka 不能脱离 zookeeper 单独使用，因为 kafka 使用 zookeeper 管理和协调 kafka 的节点服务器。

3.2.0 版本包含许多新功能和改进。本文将重点介绍一些最突出的新功能。有关更改的完整列表，请务必查看发行说明。您还可以观看发布视频，了解 Apache Kafka 3.2.0 中的新功能摘要。...