一文搞懂Kafka中的listeners配置策略
1. listeners中的plaintext controller external是什么意思？
2. Kraft模式下controller和broker有何区别？
3. 集群节点之间同步什么数据，通过哪个端口，是否可以自定义端口？
4. 客户端通过哪个端口连接到kafka，通过9092连接的是什么，broker还是controller？
5. 为controller配置了单独的端口有什么用？
6. control.plane.listener.name与controller.listener.names有何区别？
如何为Kafka加上账号密码（一）
一直以来，我们公司内网的Kafka集群都是在裸奔，只要知道端口号，任何人都能连上集群操作一番。直到有个主题莫名消失，才引起我们的警觉，是时候该考虑为它添加一套认证策略了。
基于 Flink SQL CDC 的实时数据同步方案
Flink 1.11 引入了 Flink SQL CDC，CDC 能给我们数据和业务间能带来什么变化？本文由 Apache Flink PMC，阿里巴巴技术专家伍翀 (云邪）分享，内容将从传统的数据同步方案，基于 Flink CDC 同步的解决方案以及更多的应用场景和 CDC 未来开发规划等方面进行介绍和演示。
Flink读取Kafka报Error sending fetch request
实时计算Flink读取消息队列Kafka，flink日志中出现Error sending fetch request (sessionId=1510763375, epoch=12890978) to node 103: {}.
org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException: null