RabbitMQ详细实战教程
RabbitMQ详细实战教程CSDN创作 C位CSDN创作 C位
三.Kafka入门到精通-SpringBoot整合Kafka(上)
前面两个章节我们把Kafka给安装起来然后使用命令演示是生产和消费的过程，以及Kafka的架构原理，接下来就是Kafka的实战使用，顺应如今企业流行的开发模式，当然要使用SpringBoot和Kafka进行整合。第一步：我们基于SpringBoot来快速入门Kafka，我这里使用的SpringBoo
《Kafka权威指南》中序列化章节Avro序列化的使用
《Kafka权威指南》中序列化章节Avro序列化的使用
Kafka Streams 开发单词计数应用
Kafka Streams 开发单词计数应用
docker安装kafka
本文采用docker-compose安装kafka，kafka环境是建立在zookeeper之上，安装kafka之前先安装zookeeper。创建docker-compose内容如下：运行查看运行容器运行成功日志如下：kafka安装成功会在zookeeper生成数据。使用zk客户端工具zktool
基于Java API 方式使用Kafka
基于Java API 方式使用Kafka
Kafka集群部署与测试
1、下载、解压安装包：将安装包上传到master节点中的/opt/software目录下，并将安装包解压到/opt/moduel，再命名为kafka 具体命令如下：tar -zxvf kafka-2.11-2.0.0.tgz -C /opt/modulemv kafka-2.11-2.0.0.tgz
一.Kafka入门到精通-Kafka快速入门
前言在内卷严重的程序员圈子中，原地踏步就是退步，所以不能再躺平啦，赶紧爬起来学习，接下来博主将推出《Kafka入门到精通》系列文章，让你可以在企业中玩起Kafka来得心应手，此乃升职加薪必备呀。Kafka认识Kafka 是由Linkedin公司开发的，支持多分区、多副本，基于 Zookeeper 的
Kafka中的LEO和HW
通过画图轻松理解kafka中的LEO和HW的概念与作用
Kafka调研
文章目录1. Kafka概述1.1 Kafka消费模式1.1.1 点对点模式1.1.2 发布/订阅模式1.2 Kafka的基础架构1. Kafka概述 Kafka 是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域，如海量日志的处理。1.1 Ka
一文学会基于发布订阅模式的消息队列Kafka的安装部署和基本使用
Kafka是一个分布式的基于发布/订阅模式的消息队列（MessageQueue），主要应用于大数据实时处理领域。
记一次解决jar包版本问题解决
The class hierarchy was loaded from the following locations: org.springframework.kafka.listener.ConsumerProperties:Correct the classpath of your appli
图解Kafka的RecordBatch结构
文章目录RecordBatchRecordBatch初始化写入消息Record结构图关闭ProducerBatch关闭输出流appendStream并压缩数据填充RecordBatchHeader数据RecordBatchHeader结构图RecordBatch整体结构图阅读完本文你大概会获得以下知
Python系列之：使用kafkaProducer发送数据到topic，KafkaConsumer消费topic数据
Python系列之：使用kafkaProducer生产数据，KafkaConsumer消费数据一、构建KafkaProducer二、生成数据并发送数据到Kafka Topic三、使用kafkaProducer发送数据到topic完整代码四、构建KafkaConsumer五、消费topic数据六、Ka
Apache druid安装
Apache druid运行需要依赖其他一些软件环境，所以需要先安装依赖环境，最后再安装druid。这些依赖的环境包括：jdk zookeeper kafka1 jdk安装# 解压命令tar -zxf jdk-8u191-linux-x64.tar.gz -C /usr/local/# 修改配置命令
【kafka专栏】生产级集群安装主机之间ssh免密登录
为了保证一台Linux主机的安全，每个主机登录的时候都需要账号密码。但是很多时候为了操作方便，需要设置集群互信主机之间的SSH免密码登录。
消息队列-kafka关于CommitFailedException问题
说明：转载本人掘金文章概述提交offset失败这个异常也是我们开发中常见的异常，那么这个异常是怎么引起的呢？只要我们明白原因，那么就能避免，特别是在异步提交情况下（offset丢失），导致重复消费，消息一直卡在最后一批，导致业务数据受到严重的破坏。了解消费者实例机制1.kafka消费者都是按照批量消
【NFT】ibox wtoken算法、锁单算法、脚本算法
前面的抓包分析和java层定位我这里就不分析了,添加依赖包org.apache.kafkakafka-clients2.6.0 <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-client -->
搭建ZooKeeper集群和Kafka集群
目录规划基础环境配置（1）修改主机名（2）关闭防火墙及SELinux服务（3）编辑 hosts 文件（4）配置 yum 安装源（4）安装 JDK 环境搭建 ZooKeeper 集群（1）解压 ZooKeeper 软件包（2）修改 3 个节点配置文件（3）创建 myid 文件（4）启动 ZooKeep
Zookeeper与Kafka自动部署脚本
Zookeeper与Kafka自动部署脚本
