Kafka增加安全验证安全认证，SASL认证，并通过spring boot-Java客户端连接配置
公司Kafka一直没做安全验证，由于是诱捕程序故需要面向外网连接，需要增加Kafka连接验证，保证Kafka不被非法连接，故开始研究Kafka安全验证使用Kafka版本为2.4.0版本，主要参考官方文档。
Kafka示例（Java版）
Kafka示例（Java版）
Kafka之enable.auto.commit使用解析
kafka enable.auto.commit 参数配置及意义
深入Kafka核心设计与实践原理读书笔记第二章
深入Kafka核心设计与实践原理读书笔记第二章
Kafka-kraft模式架构及部署流程
Kafka-kraft模式架构及部署流程
【消息中间件MQ系列】Spring整合kafka并设置多套kafka配置
本次的记录内容，只是简单的demo实践，具体的使用情况，可以根据自身系统设置详细配置处理。若有疑问，欢迎留言讨论~~。最后祝大家圣诞节快乐，新年快到了，继续加油吧！！！
docker-compose安装带SASL认证的kafka
本篇文章会介绍使用使用`docker-compose`安装带SASL认证的Kafka消息队列。为啥会有这篇文章主要是网上一些文章太折磨人了，都是互抄的而且都是错的。我配合`SpringBoot`调试搞了我一天。为啥要搞SASL认证也主要是为了安全考虑。如果不加认证，`Kafka`应用就是裸露在外面的
Kafka消费者订阅指定主题(subscribe)或分区(assign)详解
Kafka订阅主题（subscribe）与分区（assign）方法详解
Kafka 单机部署搭建及其基本使用
最近在搞Flink 框架 其中数据源需要模拟kafka取数据 ，于是自己搭建了一套单机的kafka环境，以便用于测试。现整理如下的笔记，发上来和大家分享。后续还会有kafka的相关笔记，会与大家继续分享！当前文档所部署服务器 IP地址为192.168.118.218 hostname 为web一、
Kafka 认证一：PlainLoginModule 认证及 Java 连接测试
项目需求是：通过 Web 页面配置 Kafka 信息并存储，且支持安全认证模式。本文介绍 Kafka 帐号密码认证的完整实践流程，自己实践一遍，才能穿起各个概念。Kafka 的 Plain 简单文本认证方式比较简单，只需要 Kafka 服务端维护用户列表，客户端同样的安全认证配置即可。
zookeeper开启SASL,并且设置kafka如何连接
zookeeper开启sasl认证
Kafka参数
配置@KafkaListener注解@KafkaListener(id = "11111", groupId = "demo-group",topics = Constants.TOPIC) public void listen(String msgData) { LOGGER.info
kafka 如何避免重复消费
1、kafka是通过offset来标记消费的。默认情况下，消费完成后会自动提交offset，避免重复消费。Kafka消费端的自动提交逻辑有一个默认的5秒间隔，也就是说在5秒之后的下一次向Broker拉取消息的时候提交。所以在Consumer消费的过程中，应用程序被强制kill掉或者宕机，可能会导致O
聊聊在springboot项目中如何配置多个kafka消费者
不知道大家有没有遇到这样的场景，就是一个项目中要消费多个kafka消息，不同的消费者消费指定kafka消息。遇到这种场景，我们可以通过kafka的提供的api进行配置即可。但很多时候我们会使用spring-kafka来简化开发，可是spring-kafka原生的配置项并没提供多个kafka配置，因此
【实时数仓】CDC简介、实现DWD层业务数据的处理（主要任务、接收kafka数据、动态分流*****）
CDC是Change Data Capture(变更数据获取)的简称。核心思想是，监测并捕获数据库的变动（包括数据或数据表的插入、更新以及删除等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。CDC主要分为基于查询和基于Binlog两种方式，主要了解一下这两种之
PHP Kafka 使用详解
PHP使用kafka进行消息订阅
【Kafka】Docker安装kafka、搭建kafka集群
docker安装kafka、搭建kafka集群进行测试
golang消息队列kafka
golang消息队列kafka
Kafka的认证
kafka认证
