Flink使用 KafkaSource消费 Kafka中的数据
很多 flink相关的书籍和网上的文章讲解如何对接 kafka时都是使用的 FlinkKafkaConsume，'org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer' is deprecated ，新版 flink应该使用 K
使用docker快速安装Kafka
快速安装kafka。
Docker安装kafka可视化管理工具 - Kafka Manager
Docker安装kafka可视化管理工具 - Kafka Manager
Spring Boot 整合kafka消费模式AckMode以及手动消费
Spring boot 批量消费kafka消息，内容就介绍下各个模式的区别。kafka支持的消费模式等常用代码功能。
【Kafka】【十三】生产者中的ack配置
在同步发送的前提下，⽣产者在获得集群返回的ack之前会⼀直阻塞。那么集群什么时候返回ack呢？下⾯是关于ack和重试（如果没有收到ack，就开启重试）的配置。
java使用assign订阅，使用SASL_SSL协议的SCRAM-SHA-256加密方式消费kafka数据
properties.put("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username='用户名' password='密码';//消费者连接的超时时间。
docker-compose安装kafka、zookeeper
将docker-compose.yml放到 /docker 目录，目录下执行。#安装docker-compose，（下载好docker-compose）#将 docker-compose 移动到相应目录。#创建kafka目录。
Flink生产数据到kafka
Flink程序生产数据至kafka。
Kafka
先进入kafka安装目录 bin下。
JAVA中Kafka配置
【代码】JAVA中Kafka配置。
Kafka消费者详解
Kafka消费者详解
Failed to send data to Kafka
kafka 异常
SpringBoot——》@KafkaListener
SpringBoot——》@KafkaListener
[Docker]使用Docker部署Kafka
Kafka 是一个分布式流处理平台，它依赖于 ZooKeeper 作为其协调服务。在 Kafka 集群中，ZooKeeper 负责管理和协调 Kafka 的各个节点。因此，要在 Docker 容器中启动 Kafka，通常需要同时启动一个 ZooKeeper 服务作为其依赖。可以按照以下步骤来启动 K
1、kafka（2.12-3.0.0）介绍、部署及验证、基准测试
Kafka是由Apache软件基金会开发的一个开源流平台，由Scala和Java编写。Publish and subscribe：发布与订阅Store：存储Process：处理Kafka生态圈官网地址：https://cwiki.apache.org/confluence/display/KAFKA
FlinkSql写入/读取Kafka
FlinkSql写入/读取Kafka
Kafka 小结
Kafka 小结
【Kafka】消息队列Kafka基础
【Kafka】消息队列Kafka基础
SpringBoot 集成 Kafka 配置
*** 自定义分区器*/@Override@Override@Override/***/@Component@Overrideif (value.toString().contains("二")){return 2;}else if (value.toString().contains("一")){
Django中如何配置kafka消息队列
Kafka是一个开源的消息队列系统，通过可扩展的、分布式的、高可用的、高吞吐量的平台，提供快速消息处理的能力。当你的web应用程序成长到一定规模时，你可能需要使用消息队列来处理异步任务、事件或在多个服务之间传递消息。在您的Django应用程序中创建一个Kafka消息处理器，用于接收和处理消息。方法创
