30、Flink SQL之SQL 客户端（通过kafka和filesystem的例子介绍了配置文件使用-表、视图等）
SQL 客户端允许用户创建用户自定义的函数来进行 SQL 查询。当前，这些自定义函数仅限于 Java/Scala 编写的类以及 Python 文件。为提供 Java/Scala 的自定义函数，你首先需要实现和编译函数类，该函数继承自 ScalarFunction、 AggregateFunction
分布式 - 消息队列Kafka：Kafka 消费者的消费位移
再考虑一种情况，当有新的消费者加入时，那么必然会有再均衡的动作，对于同一分区而言，它可能在再均衡动作之后分配给新的消费者，如果不持久化保存消费位移，那么这个新的消费者也无法知晓之前的消费位移。如下图，x 表示某一次拉取操作中此分区消息的最大偏移量，假设当前消费者已经消费了 x 位置的消息，那么我们就
如何查看Kafka的Topic消费情况
2.10为Scala版本，0.10.0.2.5.3.0为kafka版本。进入kafka安装目录，然后执行以下命令。从某一时间开始消费某一topic。从最开始开始消费某一topic。或者不指定日志输出位置和设置。
Docker 搭建 zookeeper、kafka 集群
docker 容器部署 kafka 集群
Kafka怎么保证数据不丢失，不重复
Kafka是一个分布式消息队列系统，具有高可靠性、高性能和高扩展性等特点。在数据传输过程中，Kafka采用了多种措施来保证数据的可靠性，包括数据复制、数据持久化、数据备份等。本文将从各个阶段深入分析Kafka如何保证数据不丢失、不重复，并提供代码实例来验证过程。
kafka：broker、producer、consumer常用配置
摘要 kafka参数官方文档为：https://kafka.apache.org/documentation/#producerconfigs，这里记下常用配置。broker 我们在kafka官网下载的文件比如kafka_2.11-2.4.0.tgz解包启动后就是就是kafka节点，主要
实战：彻底搞定 SpringBoot 整合 Kafka
kafka是一个消息队列产品，基于Topic partitions的设计，能达到非常高的消息发送处理性能。Spring创建了一个项目Spring-kafka，封装了Apache 的Kafka-client，用于在Spring项目里快速集成kafka。除了简单的收发消息外，Spring-kafka还提
kafka-保证数据不重复-生产者开启幂等性和事务的作用？
1.生产者开启幂等性为什么能去重
kafka--技术文档--架构体系
此外，Kafka还有一个非常重要的概念是“Consumer Group”，这是Kafka用来实现一个Topic消息的广播（发给所有的Consumer）和单播（发给任意一个Consumer）的手段。一个Topic可以有多个Consumer Group。
Kafka 和 MQTT消息中间件在车联网TSP使用浅析
Kafka 和 MQTT 是常用的消息传递协议，它们在车联网TSP中主要用于消息队列和消息发布/订阅服务。
springboot的kafka使用
springboot的kafka使用
Kafka学习笔记（高级篇）
Kafka学习笔记（高级篇）
Apache Kafka - 流式处理
Kafka被广泛认为是一种强大的消息总线，可以可靠地传递事件流，是流式处理系统的理想数据来源。流式处理系统通常是指一种处理实时数据流的计算系统，能够对数据进行实时的处理和分析，并根据需要进行相应的响应和操作。与传统的批处理系统不同，流式处理系统能够在数据到达时立即进行处理，这使得它们特别适合需要实时
【kafka面试题2】如何保证kafka消息的顺序性
【kafka面试题2】如何保证kafka消息的顺序性
Kafka的下载安装以及使用
kafka安装与使用
关于kafka压力测试（使用官方自带脚本测试）
如何测试kafka集群的性能
【Kafka】第一章
Kafka传 统定义：Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。======>什么是分布式简单来说，分布式就是将一个大问题拆分成多个小问题，逐一解决，最终协同合作，而将多个系统协同合作完成一个特定任务，支持分布式处理的软件系统，
MQ - 闲聊MQ一二事儿 （Kafka、RocketMQ 、Pulsar ）
ookeeper 是 cp 强一致架构的一种，其内部使用 zab 算法，进行信息同步和容灾，在信息量较小的情况下，性能较好，当信息交互变多，因为同步带来的性能损耗加大，性能和吞吐量降低。kafka 的整体性能收到了 topic 数量的限制，这和底层的存储有密不可分的关系，我们上面讲过，当消息来的时候
基于 kRaft 搭建单机 kafka 测试环境
使用 docker-compose 在单机搭建有三个节点的 kafka 集群。
【docker】docker安装带ui界面的kafka
使用docker-compose 一键安装kafka和kafka-ui界面
