kafka消息丢失解决方案
生产阶段: 在这个阶段，从消息在 Producer 创建出来，经过网络传输发送到 Broker 端。存储阶段: 在这个阶段，消息在 Broker 端存储，如果是集群，消息会在这个阶段被复制到其他的副本上。消费阶段: 在这个阶段，Consumer 从 Broker 上拉取消息，经过网络传输发送到 Co
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)
Java开发 - 消息队列之Kafka初体验
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而
Java开发之消息队列
简介介绍消息队列的重要性介绍Java程序员常用的Kafka消息队列介绍Kafka内部的一些机制及注意问题为什么要使用消息队列？比较常见的作用有3点，解耦、异步处理、流量削峰，这里分别一一介绍这些特点。解耦我们在设计微服务的时候经常会出现几个模块之间需要相互依赖，例如A和B服务相互依赖，那么部署一个A
Spring Kafka消费模式（single, batch）及确认模式（自动、手动）示例
1. 单记录消费listener.type=record1.1 单记录消费 - 自动确认1.2 单记录消费 - 手动确认2. 批量消费listener.type=batch2.1 批量消费 - 自动确认2.2 批量消费 - 手动确认3. 手动模式下的acknowledge和nack方法
Linux部署Kafka及常见问题记录
（物理上不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存于一个或多个broker上但用户只需指定消息的Topic即可生产或消费数据而不必关心数据存于何处）kafka消息发送的时候 ,考虑到性能 可以采用打包方式发送， 也就是说 传统的消息是一条一条发送， 现在可以先把需要发送的消息缓
kafka详解及集群环境搭建
kafka详解及集群环境搭建
RabbitMQ消息队列实战（2）—— Java调用RabbitMQ的三种方式
spring cloud stream的强大之处就在于它的封装，但是不足之处也在于它的封装，封装的太强，必然增加了学习成本和调试难度，而且类似RabbitMQ和Kafka这种中间件的使用，一般在系统创建之处就一定确定，进行无缝切换就显得有些鸡肋了。第5个参数是队列的一些结构化信息，比如声明死信队列、
Java开发 - 消息队列前瞻
常见消息队列 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ 等详解和对比 - 知乎最后了，说啥啥？还是说说关于消息队列博主的教程方向吧。后续，博主会通过两篇博客来分别讲解RabbitMQ和Kafka的实战用法，此篇权当给大家一个前瞻，了解下即可。
kafka消息重复消费解决方案
Kafka消费者以消费者组(Consumer Group)的形式消费一个topic，发布到topic中的每个记录将传递到每个订阅的消费者组中的一个消费者实例。Consumer Group 之间彼此独立，互不影响，它们能够订阅相同的一组主题而互不干涉。......
消息中间件Kafuka学习——初次配置使用
消息队列Kafuka学习
怎么避免服务内存溢出？
在高并发、高吞吐的场景下，很多简单的事情，会变得非常复杂，而很多程序并没有在设计时针对高并发高吞吐量的情况做好内存管理。自动内存管理机制的实现原理做内存管理，主要考虑申请内存和内存回收两部分。申请内存的步骤：计算要创建的对象需要占用多少内存在内存中找一块连续并且是空闲的内存空间，标记为已占用内存回收
【Linux】system V共享内存 | 消息队列 | 信号量
本篇博客主要讲解了什么是共享内存、共享内存的原理、用共享内存实现客户端和服务端的通信、什么是消息队列、消息量以及进程互斥等等。
【面试大全-MQ】-消息队列
解耦、异步、削峰解耦：一个系统或者说一个模块，调用了多个系统或者模块，互相之间很复杂，维护起来比较麻烦。但是这个接口不需要同步接口的，比如通知等，这个时候采用异步化进行解耦异步：某些操作，比如非事务操作，这个时候可以采用异步的方式削峰：减少高峰期对服务器的压力
RocketMQ源码(4)—Broker与NameServer的心跳服务源码
详细介绍了RocketMQ的Broker与NameServer的心跳服务源码。
【大话云原生】消息队列与快递柜之间妙不可言的关系（带视频）
提到消息队列可能一些朋友经常听别人说起一些名词，比如：服务程序解耦，处理流量削峰，通过异步处理提升用户体验，缓冲批处理提高处理性能。笔者擅于白话解说，所以我就不用专业的术语去解释专业的问题了。我一直觉得消息队列的功能和快递柜的功能非常相似，怎么个相似法呢？让我来详细给你说说。
CentOS 7.6环境安装kafka_2.13-3.0.0[单机版]
本节内容主要总结一下如何在CentOS 7.6上安装kafka 2.13-3.0.0注意：此单机版使用的是kafka自带的zookeeper1.组件版本组件 版本 CentOS 7.6 JDK 1.8.0_221 kafka 2.13-3.0.0 2.环境设置Init-env
RocketMQ源码解析-Broker部分之Broker启动过程
启动入口BrokerStartup
