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 文件,包括文件格式校验、元数据验证…...
2023 年 认证杯 小美赛 ABC题 国际大学生数学建模挑战赛 |数学建模完整代码+建模过程全解全析
当大家面临着复杂的数学建模问题时,你是否曾经感到茫然无措?作为2022年美国大学生数学建模比赛的O奖得主,我为大家提供了一套优秀的解题思路,让你轻松应对各种难题。 cs数模团队在认证杯 小美赛前为大家提供了许多资料的内容呀&am…...
N-134基于java实现捕鱼达人游戏
开发工具eclipse,jdk1.8 文档截图: 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:4xCortex-A53 up to 2.0Ghz/4xCortex-A53 up to 1.5GhzGraphics:IMG GE8320 Up to 650MhzProcess:12nmMemory:1xLP3 9…...
仿ChatGPT对话前端页面(内含源码)
仿ChatGPT对话前端页面(内含源码) 前言布局样式和Js部分关键点全部源码 前言 本文主要讲解如何做出类似ChatGPT的前端页面。具体我们的效果图是长这样,其中除了时间是动态的之外,其他都是假数据。接下来让我们从布局和样式的角度…...
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系统 步骤① 点击下侧任务栏中的“启动台”,进入程序坞,点击"其他",选择“启动转换助理” 步骤② 点击“继续”,接着点击“恢复”,即可卸载Windows系统 2、安装Windows系统 …...
数据库的事务的基本特性,事务的隔离级别,事务隔离级别如何在java代码中使用,使用MySQL数据库演示不同隔离级别下的并发问题
文章目录 数据库的事务的基本特性事务的四大特性(ACID)4.1、原子性(Atomicity)4.2、一致性(Consistency)4.3、隔离性(Isolation)4.4、持久性(Durability) 事务的隔离级别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,到底是什么?
相信大家在初学进程时,对fork函数创建进程一定会有很多的困惑,比如: 1.fork做了什么事情?? 2.为什么fork函数会有两个返回值?3.为什么fork的两个返回值,会给父进程谅回子进程pid,给子进程返回0?4.fork之后:父子进…...
基于SpringBoot+vue的token验证
后端: 1,写一个验证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安装完成以后,配置了一个默认的存储空间, 这个只能配置一个目录,如果要使用多个磁盘目录,则需要配置磁盘组策略 查看当前的存储策略 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…...
媒体增加日活量的有效策略
随着数字媒体的蓬勃发展,提高日活量成为媒体平台追求的重要目标之一。日活量的增加不仅意味着更广泛的影响力,还能为媒体平台带来更多的商业机会。以下是一些有效的策略,可帮助媒体提高日活量: admaoyan猫眼聚合 内容优质化&#…...
es6新特性总结
1、支持了let和const,为了防止var声明变量带来的变量提升 (1)、存在块级作用域不存在变量提升(考虑暂时性死区) (2)、不允许重复声明(包括普通变量和函数参数)变量提升…...
Spring Boot + hutool 创建海报图片
Spring Boot hutool 创建海报图片 /*** 分享,生成图片* param id* return*/GetMapping("/getShareImg")public void getShareImg(String id,HttpServletResponse response) throws IOException {CouponConsignSaleClassify byId couponConsignSaleClassifyService…...
老照片模糊发黄?别让珍贵回忆蒙尘,三步教你“复活”旧时光
在每个家庭的抽屉深处,或许都珍藏着一本厚重的相册。翻开它,泛黄的相纸、模糊的笑脸,瞬间将我们拉回到那个没有智能手机、没有高清摄像的年代。这些照片承载着父母的青春、我们的童年,是无可替代的宝贵记忆。然而,时光…...
告别Appium!用Python的uiautomator2+weditor 0.6.4搞定安卓自动化测试(附编码避坑指南)
轻量化安卓自动化测试:Python uiautomator2与weditor实战指南 在移动应用测试领域,Appium曾长期占据主导地位,但其复杂的配置环境让不少开发者望而却步。如今,基于Python的uiautomator2与weditor组合提供了一种更轻量、更高效的替…...
用Python和NumPy动手实现8种DST变换:从公式到可视化基图像
用Python和NumPy动手实现8种DST变换:从公式到可视化基图像 在信号处理领域,离散正弦变换(DST)是一组与离散余弦变换(DCT)齐名的重要工具。不同于DCT的对称延拓特性,DST通过反对称延拓方式处理信…...
1.4 大白菜磁盘分区扩容(C盘为例)
前置条件:启动盘制作完成,插入U盘,BIOS选择U盘启动1.选择“启动Win10 X64 PE”2.等待一会3.等待一会4.双击桌面“分区工具”5.可以看到C盘扩容前为41GB,D盘为19GB6.右键点击“本地磁盘(C:)”,选择“扩容分区”7.点击“…...
数字货币行情查询-加密货币行情-虚拟币行情查询API接口介绍
前言 面向开发者、量化交易团队、金融应用、行情网站、区块链工具等用户,提供标准化、稳定、低延迟的数字货币 / 加密货币 / 虚拟币实时行情、历史 K 线、交易对、深度盘口、成交记录、市值排行等全维度数据查询能力。旨在解决开发者快速接入加密货币市场数据、构建…...
【MATLAB代码介绍】三种CT模型的IMM(交互式多模型)对目标高精度定位
三个CT模型,分别是旋转速率不同,适用于定位、导航、目标跟踪 原创代码,包运行成功,禁止翻卖 文章目录代码介绍场景概述算法核心:三模型 IMMIMM 算法的四个关键步骤主要功能与输出适用场景代码构成运行结果源代码代码介…...
[1]锁相环 PLL 几个版本的matlab相位噪声拟合仿真代码,质量杠杠的,都是好东西
[1]锁相环 PLL 几个版本的matlab相位噪声拟合仿真代码,质量杠杠的,都是好东西 [2]锁相环matlab建模稳定性仿真,好几个版本 [3]锁相环2.4G小数分频 simulink建模仿真最近在折腾锁相环设计,发现手头这几个版本的Matlab相位噪声拟合…...
经济研究论文排版终极指南:如何用LaTeX模板快速完成学术投稿
经济研究论文排版终极指南:如何用LaTeX模板快速完成学术投稿 【免费下载链接】Chinese-ERJ 《经济研究》杂志 LaTeX 论文模板 - LaTeX Template for Economic Research Journal 项目地址: https://gitcode.com/gh_mirrors/ch/Chinese-ERJ 还在为《经济研究》…...
8大网盘直链获取指南:告别限速的浏览器脚本解决方案
8大网盘直链获取指南:告别限速的浏览器脚本解决方案 【免费下载链接】Online-disk-direct-link-download-assistant 一个基于 JavaScript 的网盘文件下载地址获取工具。基于【网盘直链下载助手】修改 ,支持 百度网盘 / 阿里云盘 / 中国移动云盘 / 天翼云…...
