一、概述 最近有项目要测试kafka连接可用性，本地搭建模拟环境测试一下，本文作为一个记录。 二、部署 2.1环境准备 本次采用Centos7.9安装，因为kafka和zookeeper都需要用到jdk，这次安装的使用oraclejdk8https://www.oracle.com/java/technologies/javase/javase8u211-later-archive-downloads.html在服务器上下载jdk软件包在服务器上安装jdk软件包检查java的环境变量是否生效 2.2准备应用软件包 kafka下载链接当前版本3.4.0：https://downloads.apa...

一、概述 上回已经完成kafka+zookeeper的基础功能的实现，但是因为默认不认证存在很大的安全风险，这次完成SASL_PLAINTEXT的认证类型实践。 二、安全配置 2.1zookeeperSASL配置部分 2.1.1创建conf/java.env文件，添加以下配置信息 exportSERVER_JVMFLAGS="-Djava.security.auth.login.config=/opt/soft/zookeeper/conf/sasl.conf-Dzookeeper.allowSaslFailedClients=false" exportCLIENT_JVMFLAGS="-Dj...

概述 最近在部分项目上需要用到python登陆ssh的方法，作为一个小白，对该登陆方法一进行一个实践。 实践 代码 importparamiko ssh=paramiko.SSHClient() defssh_login(ip,port,username,password): globalssh ssh=paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(ip,port,username,password) return defssh_exe_cmd(cm...