当前位置: 首页 > news >正文

Kafka配置SASL认证密码登录

​​​​​​1、修改config/server.properties,添加如下内容

listeners=SASL_PLAINTEXT://内网ip:9092
advertised.listeners=SASL_PLAINTEXT://外网ip:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN

2、添加相关安全认证配置文件

在config目录下添加kafka-zk-jaas.conf

zookeeper {org.apache.kafka.common.security.plain.PlainLoginModule requiredusername="admin"password="xxxxxx";
};

在config目录下添加kafka-server-jaas.conf

KafkaServer {org.apache.kafka.common.security.plain.PlainLoginModule requiredusername="admin"password="xxxxxx"user_admin="xxxxxx";
};

在config目录下添加kafka-client-jaas.conf

KafkaClient {org.apache.kafka.common.security.plain.PlainLoginModule requiredusername="admin"password="xxxxxx";
};

3、修改相关启动文件应用上面添加的配置文件去启动

修改zookeeper-server-start.sh,在exec前一行添加:

export KAFKA_OPTS="-Djava.security.auth.login.config=file:$base_dir/../config/kafka-zk-jaas.conf"

修改kafka-server-start.sh,在exec前一行添加:

export KAFKA_OPTS="-Djava.security.auth.login.config=file:$base_dir/../config/kafka-server-jaas.conf"

修改kafka-console-consumer.sh,在exec前一行添加:

export KAFKA_OPTS="-Djava.security.auth.login.config=file:$(dirname $0)/../config/kafka-client-jaas.conf"

修改kafka-console-producer.sh,在exec前一行添加:

export KAFKA_OPTS="-Djava.security.auth.login.config=file:$(dirname $0)/../config/kafka-client-jaas.conf"

4、修改springboot配置

spring.kafka.bootstrap-servers=外网ip:9092
spring.kafka.properties.security.protocol=SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism=PLAIN
spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="xxxxxx";
spring.kafka.consumer.properties.sasl.mechanism=PLAIN
spring.kafka.consumer.properties.security.protocol=SASL_PLAINTEXT

5、kafka启动停止命令

切换到kafka安装目录:cd /home/kafka_2.13-2.6.0/

zookeeper启动命令:./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

kafka启动命令:./bin/kafka-server-start.sh -daemon config/server.properties

kafka停止命令:./bin/kafka-server-stop.sh

zookeeper停止命令:./bin/zookeeper-server-stop.sh

查看zookeeper是否启动成功:ps -ef | grep zookeeper

查看kafka是否启动成功:ps -ef | grep kafka

相关文章:

Kafka配置SASL认证密码登录

​​​​​​1、修改config/server.properties,添加如下内容 listenersSASL_PLAINTEXT://内网ip:9092 advertised.listenersSASL_PLAINTEXT://外网ip:9092 security.inter.broker.protocolSASL_PLAINTEXT sasl.mechanism.inter.broker.protocolPLAIN sasl.enabled.…...

两年功能五年自动化测试面试经验分享

最近有机会做一些面试工作,主要负责面试软件测试人员招聘的技术面试。 之前一直是应聘者的角色,经历了不少次的面试之后,多少也积累一点面试的经验,现在发生了角色转变。初次的面试就碰到个工作年限比我长的,也没有时…...

大数据基础设施搭建 - Kafka(with ZooKeeper)

文章目录 一、简介二、单机部署2.1 上传压缩包2.2 解压压缩包2.3 修改配置文件(1)配置zookeeper地址(2)修改kafka运行日志(数据)存储路径 2.4 配置环境变量2.5 启动/关闭2.6 测试(1)查看当前服务器中的所有…...

[JVM] 京东一面~说一下Java 类加载过程

系统加载 Class 类型的文件主要三步:加载->连接->初始化。连接过程又可分为三步:验证->准备->解析。 通过全限定名来加载生成 class 对象到内存中,然后进行验证这个 class 文件,包括文件格式校验、元数据验证&#xf…...

2023 年 认证杯 小美赛 ABC题 国际大学生数学建模挑战赛 |数学建模完整代码+建模过程全解全析

当大家面临着复杂的数学建模问题时,你是否曾经感到茫然无措?作为2022年美国大学生数学建模比赛的O奖得主,我为大家提供了一套优秀的解题思路,让你轻松应对各种难题。 cs数模团队在认证杯 小美赛前为大家提供了许多资料的内容呀&am…...

N-134基于java实现捕鱼达人游戏

开发工具eclipse,jdk1.8 文档截图&#xff1a; package com.qd.fish;import java.awt.Graphics; import java.io.File; import java.util.ArrayList; import java.util.List;import javax.imageio.ImageIO;public class Fishes {//定义一个集合来管理鱼List<Fish> fish…...

MTK联发科MT6762/MT6763/MT6765安卓核心板参数规格比较

MT6762安卓核心板 MTK6762安卓核心板是一款工业级高性能、可运行 android9.0 操作系统的 4G智能模块。 CPU&#xff1a;4xCortex-A53 up to 2.0Ghz/4xCortex-A53 up to 1.5GhzGraphics&#xff1a;IMG GE8320 Up to 650MhzProcess&#xff1a;12nmMemory&#xff1a;1xLP3 9…...

仿ChatGPT对话前端页面(内含源码)

仿ChatGPT对话前端页面&#xff08;内含源码&#xff09; 前言布局样式和Js部分关键点全部源码 前言 本文主要讲解如何做出类似ChatGPT的前端页面。具体我们的效果图是长这样&#xff0c;其中除了时间是动态的之外&#xff0c;其他都是假数据。接下来让我们从布局和样式的角度…...

js粒子效果(一)

效果: 代码: <!doctype html> <html> <head><meta charset"utf-8"><title>HTML5鼠标经过粒子散开动画特效</title><style>html, body {position: absolute;overflow: hidden;margin: 0;padding: 0;width: 100%;height: 1…...

程序员必备工具篇 / 程序员必备基础:Git

前言 掌握 Git 命令是每位程序员必备的基础,之前一直是用 smartGit 工具,直到看到大佬们都是在用 Git 命令操作的,回想一下,发现有些 Git 命令我都忘记了,于是写了这篇博文,复习一下~ https://github.com/whx123/JavaHome 公众号:顺哥轻创 文章目录 Git 是什么?Git …...

MacBook使用指南

一、安装及卸载Windows系统 1、卸载Windows系统 步骤① 点击下侧任务栏中的“启动台”&#xff0c;进入程序坞&#xff0c;点击"其他",选择“启动转换助理” 步骤② 点击“继续”&#xff0c;接着点击“恢复”&#xff0c;即可卸载Windows系统 2、安装Windows系统 …...

数据库的事务的基本特性,事务的隔离级别,事务隔离级别如何在java代码中使用,使用MySQL数据库演示不同隔离级别下的并发问题

文章目录 数据库的事务的基本特性事务的四大特性(ACID)4.1、原子性&#xff08;Atomicity&#xff09;4.2、一致性&#xff08;Consistency&#xff09;4.3、隔离性&#xff08;Isolation&#xff09;4.4、持久性&#xff08;Durability&#xff09; 事务的隔离级别5.1、事务不…...

Robust taboo search for the quadratic assignment problem-二次分配问题的鲁棒禁忌搜索

文章目录 摘要关键字结论研究背景1. Introduction 常用基础理论知识2. The quadratic assignment problem3. Taboo search3.1. Moves3.2 Taboo list3.3. Aspiration function3.4. Taboo list size4. Random problems5. Parallel taboo search 研究内容、成果7. Conclusion 潜在…...

Linux:创建进程 -- fork,到底是什么?

相信大家在初学进程时&#xff0c;对fork函数创建进程一定会有很多的困惑&#xff0c;比如&#xff1a; 1.fork做了什么事情?? 2.为什么fork函数会有两个返回值?3.为什么fork的两个返回值&#xff0c;会给父进程谅回子进程pid&#xff0c;给子进程返回0?4.fork之后:父子进…...

基于SpringBoot+vue的token验证

后端&#xff1a; 1&#xff0c;写一个验证token的拦截器 import com.fasterxml.jackson.databind.ObjectMapper; import com.ffyc.news.model.CommonData; import org.springframework.web.servlet.HandlerInterceptor;import javax.servlet.http.HttpServletRequest; impor…...

Clickhouse设置多磁盘存储策略

设置多磁盘存储 clickhouse安装完成以后&#xff0c;配置了一个默认的存储空间&#xff0c; 这个只能配置一个目录&#xff0c;如果要使用多个磁盘目录&#xff0c;则需要配置磁盘组策略 查看当前的存储策略 select name, path, formatReadableSize(free_space) as free, fo…...

Python开发运维:Django 4.2.7 使用Celery 5.3.5 完成异步和定时任务

目录 一、实验 1.Django使用Celery完成异步和定时任务 二、问题 1. 如何查看Django版本 一、实验 1.Django使用Celery完成异步和定时任务 (1)安装Django (2)新建Django项目 (3)初始框架 (4)urls.py引用视图views from django.contrib import admin from django.urls imp…...

媒体增加日活量的有效策略

随着数字媒体的蓬勃发展&#xff0c;提高日活量成为媒体平台追求的重要目标之一。日活量的增加不仅意味着更广泛的影响力&#xff0c;还能为媒体平台带来更多的商业机会。以下是一些有效的策略&#xff0c;可帮助媒体提高日活量&#xff1a; admaoyan猫眼聚合 内容优质化&#…...

es6新特性总结

1、支持了let和const&#xff0c;为了防止var声明变量带来的变量提升 &#xff08;1&#xff09;、存在块级作用域不存在变量提升&#xff08;考虑暂时性死区&#xff09; &#xff08;2&#xff09;、不允许重复声明&#xff08;包括普通变量和函数参数&#xff09;变量提升…...

Spring Boot + hutool 创建海报图片

Spring Boot hutool 创建海报图片 /*** 分享,生成图片* param id* return*/GetMapping("/getShareImg")public void getShareImg(String id,HttpServletResponse response) throws IOException {CouponConsignSaleClassify byId couponConsignSaleClassifyService…...

别再只会AT指令了!用STM32CubeMX+正点原子LoRa模块,5分钟搞定透明传输

STM32CubeMX与正点原子LoRa模块的高效开发指南 在嵌入式开发领域&#xff0c;LoRa技术因其长距离、低功耗的特性广受欢迎&#xff0c;但传统的AT指令配置方式往往让开发者陷入繁琐的底层调试中。本文将带你体验STM32CubeMX图形化工具与正点原子LoRa模块的完美结合&#xff0c;告…...

别再死记硬背!用Python实战演练《软件工程导论》课后习题(详细设计篇)

用Python实战演练《软件工程导论》详细设计习题 当翻开《软件工程导论》的详细设计章节&#xff0c;那些抽象的控制结构转换题是否让你感到无从下手&#xff1f;本文将带你用Python代码重新演绎经典课后习题&#xff0c;让枯燥的理论在编程实践中变得生动可感。我们不仅会实现S…...

避坑指南:ESP32搭配百度TTS时,采样率设置不对声音就‘哑巴’了

ESP32音频开发实战&#xff1a;精准匹配百度TTS采样率与硬件配置的避坑指南 当你在ESP32项目中使用百度语音合成&#xff08;TTS&#xff09;功能时&#xff0c;是否遇到过这样的场景——代码逻辑看似完美&#xff0c;但播放出来的声音却像被掐住脖子一样嘶哑断续&#xff1f;这…...

【会议征稿通知 | 东北农业大学主办 | ACM出版 | EI 、Scopus稳定检索】第二届智慧农业与人工智能国际学术会议(SAAI 2026)

第二届智慧农业与人工智能国际学术会议&#xff08;SAAI 2026&#xff09; 2026 2nd International Conference on Smart Agriculture and Artificial Intelligence 2026年5月29-31日 中国西安&#xff08;线上/线下均可参会) 大会官网&#xff1a;www.icsaai.org 截稿时…...

告别数据丢失!用AT24C512大容量EEPROM为你的STM32项目做个可靠的数据保险箱

告别数据丢失&#xff01;用AT24C512大容量EEPROM为你的STM32项目做个可靠的数据保险箱 在嵌入式开发中&#xff0c;数据丢失是个让人头疼的问题。想象一下&#xff0c;设备突然断电&#xff0c;所有运行参数和用户设置瞬间归零——这种场景对任何产品都是灾难性的。而AT24C512…...

手把手教你用U盘和rEFInd救活你的多系统电脑(Win10/Linux引导修复指南)

手把手教你用U盘和rEFInd救活你的多系统电脑&#xff08;Win10/Linux引导修复指南&#xff09; 当你按下电源键&#xff0c;屏幕却只显示"Boot Device Not Found"或陷入Grub Rescue的黑白界面时&#xff0c;这种绝望感每个折腾多系统的用户都深有体会。去年我的开发…...

别再手动找Bug了!手把手教你用Fortify SCA 2023快速扫描Java项目(附内存优化技巧)

告别低效查错&#xff1a;Fortify SCA 2023在Java项目中的实战应用指南 每次提交代码前&#xff0c;你是否会为潜在的安全漏洞而焦虑&#xff1f;那些隐藏在数千行代码中的SQL注入、XSS攻击风险点&#xff0c;往往需要耗费大量时间人工排查。传统的手动代码审查不仅效率低下&am…...

2026降AI率工具性价比比拼:SpeedAI凭实力突围

2026年毕业季临近&#xff0c;不少同学都在问&#xff1a;现在哪款降AI工具性价比最高&#xff1f;这个问题其实很难一概而论&#xff0c;毕竟“性价比”对不同人来说标准完全不同&#xff1a;有人觉得单价低就是性价比高&#xff0c;有人觉得功能全更重要&#xff0c;还有人只…...

别光画点线了!用OpenGL+OpenCV把绘图结果保存成图片文件

从OpenGL绘图到图像文件&#xff1a;高效保存渲染结果的实战指南 在计算机图形学项目中&#xff0c;我们经常需要将OpenGL实时渲染的图形保存为标准的图像文件。无论是为了生成演示材料、制作实验报告&#xff0c;还是为了后续的图像处理分析&#xff0c;掌握这一技能都至关重要…...

避坑指南:用vprbs做SerDes链路仿真时,你的PRBS序列真的设对了吗?

高速SerDes验证实战&#xff1a;vprbs参数配置与PRBS序列生成深度解析 在高速串行接口(SerDes)验证领域&#xff0c;PRBS(伪随机二进制序列)测试堪称链路性能评估的"黄金标准"。作为芯片验证工程师&#xff0c;我们经常需要在Cadence仿真环境中使用analogLib库的vprb…...