测试开发真的不难（8）启动Zookeeper报错ZooKeeper audit is disabled【已解决】
今天在启动Kakfa+Zookeeper时遇见了报错：ZooKeeper audit is disabled。对于3.6和3.2版本的解决方式做了下总结，直接看这篇就可以啦！
RabbitMQ如何实现延时队列
RabbitMQ实现延时队列
zookeeper 安装下载与集群
my_env.sh是自己创建的环境变量文件，你也可以自己创建。配置集群信息和日志路径还有data路径。三个重新启动发现就可以看可以了。发现起不来，查看日志信息发现。记得source环境变量。在你配置的data路径下。创建myid文件，记得。
kafka生产者api和数据操作
kafka生产者api和数据操作
kafka接收外部接口的数据，并实现转发
JAVA实现kafka接收外部接口的数据，并实现转发。
Spark 并行度
Spark中并行度设置
Rabbitmq消息积压问题如何解决？
Rabbitmq消息积压问题如何解决？
用户认证——Kerberos集成Hadoop的配置
Hadoop Kerberos配置
Kafka指定分区消费及consumer-id,client-id相关概念解析
在最近使用Kafka过程中，发现使用@KafkaListener指定分区消费时（指定了所有分区），如果服务是多节点，会出现重复消费的现象，即两个服务节点中的消费者均会消费到相同信息，这与消费者组中只有一个消费者可以消费到消息的规则不相符，于是花时间找了找原因Consumer 机制小龙虾你抓不到(上面
python消费kafka数据
上一篇文章是生产数据：python向kafka发送json数据_grfstc的博客-CSDN博客1.安装kafka支持库2.创建python文件3.运行该python文件注意：该python文件会持续消费kafka数据，如果要停止消费，需手动退出程序。或者可以设置达到特定偏移量退出for循环来停止消
Kafka - Topic命令 & 命令行操作
Kafka - Topic Command & Command Line Operations
[spark]spark资源分配
(1*4即4个节点共4个executor)*4=16，总cpu为32线程 8/16=1/2。每个executor内存数=该节点可用的总内存数/该节点executor数=16G/1=19G(这里因为executor num实在太小，所以随便选了16)但是一般cpu:内存=1:2-1:4，阿里云封装的时
4、Zookeeper分布式安装部署
集群模式下配置一个文件myid，这个文件在dataDir目录下，这个文件里面有一个数据就是A的值，Zookeeper启动时读取此文件，拿到里面的数据与zoo.cfg里面的配置信息比较从而判断到底是哪个server。（1）重命名/opt/module/zookeeper/conf这个目录下的zoo_s
如何解决RabbitMQ中的延迟消息问题
首先我们要知道什么是死信？一般呢？一旦消息变成死信是会被我们丢弃的，但是有了死信交换机就不一样了。如果这个包含死信的队列配置了dead-letter-exchange属性，指定了一个交换机，那么队列中的死信就会投递到这个交换机中，而这个交换机称为死信交换机（Dead Letter Exchange，
RabbitMQ介绍及部署（超详细讲解）
rabbitmq
RabbitMQ的使用详解
MQ（message queue），本质是个队列，FIFO先入先出。只不过队列中放的是message，是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ是一种非常常见的上下游解耦的消息通信服务。使用了MQ之后，消息发送上游只需要依赖MQ，不用依赖其他服务。
工具篇--4.1RabbitMq--常用配置参数详解
控制使用一个 RabbitMQ 连接创建的 channel 数量，即 RabbitMQ 连接池中缓存连接时每个连接中的 channel 的数量，缓存的目的是减少连接和销毁的开销。sring.rabbitmq.cache.channel.checkout-timeout 是 Spring Boot 集
虚拟机中安装RabbitMQ及使用（超详细）
虚拟机中安装RabbitMQ及使用
kafka通过命令行删除指定topic下所有records
由于在windows环境下，在kafka官网下载下来。
RabbitMQ知识掌握 【进阶篇】
1] 保证消息的可靠性投递: confirm机制和return机制[2] 队列中:—持久化[3]使用ack机制保证消费者的可靠性消费。
