Kafka：Topic概念与API介绍
Topic事件被组织并持久地存储在Topic中，Topic类似于文件系统中的文件夹，事件就是该文件夹中的文件。Kafka中的Topic始终是多生产者和多订阅者：一个Topic可以有零个、一个或多个生产者向其写入事件，也可以有零个、一个或多个消费者订阅这些事件。Topic中的事件可以根据需要随时读取，
kafka 消费者相关参数
kafka消费者ConsumerConfig相关配置参数（enable.auto.commit、max.poll.interval.ms、max.poll.records、auto.commit.interval.ms、session.timeout.ms），及参数默认值、详细说明等，帮助熟悉kaf
KAFKA学习
kafka学习
Kafka服务端参数配置
介绍了kafka服务端的一些配置
Python之Kafka安装与使用
目录一、kafka基础概念了解二、下载安装Kafka三、KafkaTool可视化工具四、python操作kafka1、生产者代码2、消费者代码一、kafka基础概念了解Kafka是一种高吞吐量、持久性、分布式的发布订阅的消息队列系统kafka文档为什么应该学习 KafkaKafka 里面的信息是如何
利用Kafka实现延迟队列实践
上面的实践存在什么样的问题，考虑一个场景，有一个延迟一小时的队列，这样消息发出后，实际上一个小时后在该主题上的消息拉取才有意义（之前即使拉取下来也发送不出去），但上面的实现仍然会不停阻塞唤醒，相当于在做无用功。主要实践原理是通过定阅原始主题，并判断是否满足延迟时间要求，满足要求后转发新主题，不满足则
三、Kafka消费者
消费者（Consumer）负责订阅Kafka主题，并从订阅的主题上拉取消息。与其它消息中间件不同的是：Kafka消费理念中还有一层消费者组（Consumer Group）的概念，一个消费者组包含多个消费者，消息发布到主题后，会投递给每个消费者组中的其中一个消费者。如上图，一个主题有四个分区，P0、P
kafka开kerberos认证报错the client is being asked for a password
在Kafka工程 且开 kerberos 时，遇到报错：Could not login: the client is being asked for a password, but the Kafka client code does not currently support obtaining
FLink多表关联实时同步
Oracle->Debezium->Kafka->Flink->PostgreSQLFlink消费Kafka中客户、产品、订单（ID）三张表的数据合并为一张订单（NAME）表。
【kafka】三、kafka命令行操作
kafka命令行操作kafka的相关操作命令脚本文件在bin目录下。
Springboot整合kafka
Springboot 整合kafka ，简单实现
Kafka处理单条超大信息的解决办法
Kafka处理单条超大信息的解决办法
kafka3.4.0集群搭建（无zookeeper）
2.8版本及以上kafka集群搭建，移除zookeeper
如何查看kafka的topic的消费者组有没有积压
如何查看kafka的topic的消费者组有没有积压
Kafka入门使用
Kafka是一个分布式消息队列，因其可水平扩展和高吞吐率而被广泛使用！kafka的安装与使用（Windows）1、运行zookeeper，下载与安装可见：https://blog.csdn.net/z1790424577/article/details/1066607642、下载kafka，地址为：
Kafka消息中间件（Kafka与MQTT区别）
数据模型不同：Kafka以分布式的方式存储数据，数据按照主题分区存储，每个分区都有多个副本，可以通过分区键选择分区，消费者可以根据分区键并行消费数据。总的来说，Kafka更加适合处理大规模的实时数据，具有高吞吐量、低延迟和高可靠性的特点，而MQTT适用于轻量级的实时数据传输，具有简单易用和广泛支持的
实战：kafka、zookeeper SASL+ACL实现动态权限认证、授权
kafka基于SASL/SCRAM 集合zookeeper SASL，实现安全认证、权限校验ACL。
【Kafka】MM2同步Kafka集群时如何自定义复制策略(ReplicationPolicy)
使用MM2同步集群数据，默认的复制策略为：DefaultReplicationPolicy，这个策略会把同步至目标集群的topic都加上一个源集群别名的前缀，比如源集群别名为A，topic为：bi-log，该topic同步到目标集群后会变成：A.bi-log，为啥这么做呢，就是为了避免双向同步的场景
Kafka 入门篇（二）
生产者分区机制分区策略顺序轮询随机轮询按照 key 进行消息保存生产者压缩机制Kafka 压缩是什么Kafka 重要参数配置key.serializervalue.serializeracksbuffer.memorycompression.typeretriesbatch.sizeclient.i
FlinkSql开窗实例：消费kafka写入文本
以前写Flink从kafka入hdfs因为业务需求和老版本缘故都是自定义BucketSink入动态目录中，对于简单的需求可以直接用Flink SQL API进行输出。Flink版本1.13.1。
