部署zkhttps://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.9.1/apache-zookeeper-3.9.1.tar.gztar-xfapache-zookeeper-3.9.1.tar.gz-C/appscd/apps/&&ln-sapache-zookeeper-3.9.1zookeeper修改配置```bashgrep-vE'^$|^#'conf/zoo.cfgtickTime=2000initLimit=10syncLimit=5dataDir=/apps/zookeeper/dataclientPor
此篇答案参考网上答案:知乎:lchatgpt调用api接口出现连接不上的错误不过他的问题是“由于连接方在一段时间后没有正确答复或连接的主机没有反应，连接尝试失败”，而我的问题是"Pythonrequests.exceptionTLS/SSLconnectionhasbeenclosed(EOF)(_ssl.c:1131)"解决方法都一样，将环境里的urllib3版本进行降级，降到1.25.11condalist发现我自己的urlib3是2.X版本的，故直接降级，执行以下指令进行覆盖pipinstallurllib3==1.25.11降级后，问题解决
必须打开第二步的设置，不然拔下数据线的时候，就会出现连接异常，导致无法连接手机会出现cannotconnectto192.168.1.101:5555:由于目标计算机积极拒绝，无法连接。(10061)1.先用USB线连接手机和电脑2.打开开发者模式，勾选USB调试，和“仅充电”模式下允许ADB调试（这两步很重要）（其他手机有adb网络调试的也可以打开）3.打开终端输入adbdevices出现这个说明USB线连接成功4.接着输入adbtcpip5555（这个是从usb模式切换到无线连接，后面的5555为端口，可以指定其他的端口，前提是端口未被调用）5.输入adbconnect192.168.xx
🎉🎉欢迎来到我的CSDN主页！🎉🎉🏅我是尘缘，一个在CSDN分享笔记的博主。📚📚👉点击这里，就可以查看我的主页啦！👇👇尘缘的个人主页🎁如果感觉还不错的话请给我点赞吧！🎁🎁💖期待你的加入，一起学习，一起进步！💖💖目录1安装JDK2安装ZOOKERPER3安装并运行KAFKA1安装JDK1、下载文件：https://www.oracle.com/java/technologies/downloads/#jdk17-windows下载对应windows使用的jdk。2、安装JDK并设置环境变量，JAVA_HOME和path3、打开cmd，输入java-version，验证java是否安装成功；2安装
Elk+Filebeat+Kafka实现日志收集(本机nginx)部署Zookeeper1.实验组件#准备3台服务器做Zookeeper集群20.0.0.1020.0.0.2020.0.0.302.安装前准备#关闭防火墙systemctlstopfirewalldsystemctldisablefirewalldsetenforce0#安装JDKyuminstall-yjava-1.8.0-openjdkjava-1.8.0-openjdk-develjava-version#将apache-zookeeper-3.5.7-bin.tar.gz压缩包上传至/opt目录3.安装Zookeeper
文章目录前言docker-compose快速搭建kafka集群（较详细）docker-compose快速搭建Zookeeper集群+kafka集群参考资料前言当前是在学习kafka3.0的教程，基于需求就进行搭建了kafka集群，kafka在2.8.0之前是需要zookeeper的，之后可以不需要依赖了，目前的部署方案是基于zookeeper集群的情况下进行的，若是你还没有搭建zookeeper集群，可见：docker-compose快速搭建Zookeeper集群。我自己搭建录制了个视频见：docker-compose快速搭建zookeeper集群以及kafka集群所有博客文件目录索引：博客目
上一篇介绍了zookeeper的作用以及原理，这一篇我们介绍消息中间件kafka以及为什么要用kafka，什么业务场景下需要kafka，还有不同业务场景应该用哪一种消息中间件。最后还有kafka集群的搭建。注，kafka从2.8版本开始已经在逐步取消依赖zookeeper了，本文依赖zookeeper以及不依赖zookeeper改用Kraft模式都会介绍。kafka是什么在说kafka是什么之前，我们应该先知道，消息中间件是什么。举个例子，大家网上买东西，现在很多时候都会放到驿站或者快递柜，而不是快递员直接送到你手上，然后你什么时候去取快递，那就是你的事了，那在这个过程中，中间的这个驿站或者快
kafka报错报错信息一：启动Kafka出现TheClusterIDdoesn’tmatchstoredclusterId错误需要删除在kafka路径下面的logs里面的meta.properties，这是因为cluster.id不匹配报错信息二：ERRORorg.apache.kafka.common.errors.InvalidReplicationFactorException:Replicationfactor:2largerthanavailablebrokers:1.(kafka.admin.TopicCommand$)出现这个错误可以去查看kafka下面的advertised后面
目录一、Kafka事务性消息1.1介绍Kafka事务性消息1.2事务性消息的应用场景1.3Kafka事务性消息的优势二、Kafka事务性消息的使用2.1配置Kafka以支持事务性消息生产者配置消费者配置2.2生产者：发送事务性消息创建Kafka生产者开始事务发送消息提交或中止事务2.3消费者：处理事务性消息创建Kafka消费者订阅主题处理消息提交位移三、事务性消息的最佳实践3.1保障消息的一次交付3.1.1生产者幂等性3.1.2消费者去重3.2事务性消息的监控和故障排查3.2.1监控工具3.2.2故障排查3.3事务性消息的性能考量3.3.1性能调整3.3.2吞吐量优化四、示例：生产和消费Kaf
目录kafka是什么TopicPartitionBrokerCousumerCousumerGroupOffsetreblancebroker消息存储Isrkafka是什么Kafka 是一个分布式的消息引擎，能够发布和订阅消息流（类似于消息队列）以容错的、持久的方式存储消息流多分区概念，提高了并行能力。架构如下图：Topic消息的主题、队列，每一个消息都有它的topic，Kafka通过topic对消息进行归类。Kafka中可以将Topic从物理上划分成一个或多个分区（Partition），每个分区在物理上对应一个文件夹，以”topicName_partitionIndex”的命名方式命名，该d
