Kafka 之消息同步/异步发送
前面我们对 Kafka 有了一个基本的认识，完成了 Spring Boot 项目集成 Kafka，并实现了消息发送和消费，本篇来分享一下 Kafka 的同步、异步消息发送。
Kafka 之批量消息发送消费
前面我们分享了 Kafka 的一些基础知识，以及 Spring Boot 集成 Kafka 完成消息发送消费，本篇我们来分享一下 Kafka 的批量消息发送消费。
Kafka 之消息广播消费
上一篇我们分享了 Kafka 批量消息相关的知识，本篇我们继续分享 Kafka 的广播消费。
RocketMQ 之消息消费手动提交 ACK 实战【案例分享】
上一篇我们分享了 RocketMQ 消息重试的一些基本原理，本篇我们基于 Spring Boot 整合 RocketMQ 来分享一下 RocketMQ 消息基于手动提交的案例，在分享手动进行消息 ACK 中也会分享消息重试的使用。
Kafka 客户端工具使用分享【offsetexplorer】
前面我们使用 Spring Boot 继承 Kafka 完成了消息发送，有朋友会问 Kafka 有没有好用的客户端工具，RabbitMQ、RocketMQ 都有自己的管理端，那 Kafka 如何去查看发送出去的消息呢？本篇我们就来分享一个好用的工具。offsetexplorer 中数据默认显示是 B
kafka-clients之mq丢失问题
客户端版本为2.6.x，客户端机器可能在尝试连接 Kafka broker 时因为超时断开，导致无法成功接收或更新 metadata由于客户端没有及时感知到broker重新选举的metadata数据，一直尝试向宕机的broker发送mq，在2分钟后超时，最终失败导致部分mq消息丢失如何解决该问题场景
Spring Boot 整合 Kafka 详解
上一篇分享了 Kafka 的一些基本概念及应用场景，本篇我们来分享一下在 Spring Boot 项目中如何使用 Kafka。
Kafka消息积压的典型场景及解决方案
Kafka消息积压的典型场景及解决方案
Kafka - This server does not host this topic-partition
Kafka - This server does not host this topic-partition
RabbitMQ 的事务消息了解吗【RabbitMQ 事务消息实战】
我们知道 RabbitMQ 保证消息一定会发送成功，一般有两种方式，分别是 Publisher Confirm 机制和事务消息，上一篇我们分享了如果使用 RabbitMQ Publisher Confirm 机制来保证消息一定发送成功，本篇我们来分享使用 RabbitMQ 事务消息保证消息一定会
2024消息队列“四大天王”：Rabbit、Rocket、Kafka、Pulsar巅峰对决
在选择合适的消息队列或消息传递系统时，了解各个系统的特点和优势非常重要。
Kafka详解
发布者和订阅者之间有时间上的依赖性：针对某个主题的订阅者，它必须创建一个订阅之后，才能消费发布者的消息，而且为了消费消息，订阅者必须保持运行的状态。半数以上完成同步才可以发ACK，如果挂了n台有副本的服务器，那么就需要有另外n台正常发送（这样正常发送的刚好是总数（挂的和没挂的）的一半（n（挂的）+n
kafka可视化工具Kafka Tool安装使用
Kafka Tool是一款 Kafka 的可视化客户端工具，可以非常方便的查看 Topic 的队列信息、消费者信息以及 kafka 节点信息。官网地址: https://www.kafkatool.com/download.html。下载对应系统架构的kafkatool包。连接成功后,查询Topic
使用RabbitMQ，关键点总结
AMQP，即 Advanced Message Queuing Protocol（高级消息队列协议），是一个网络协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。2006年，AMQP 规范发布
Kafka
Kafka
Kafka的ACK应答级别
在 Kafka 中，ACK（Acknowledgement）应答级别是一个重要的概念，它决定了消息发送到 Kafka 集群后如何确认消息的成功存储。生产者可以根据需要设置不同的 ACK 级别，以在数据可靠性和传输效率之间做出权衡。选择哪个 ACK 级别取决于具体的应用场景和对数据可靠性与处理吞吐量的
Kafka 记录
在一个Kafka集群中，每增加一个代理就需要为这个代理配置一个与该集群中其他代理不同的id, id值可以选择任意非负整数即可，只要保证它在整个Kafka集群中唯一，这个id就是代理的名字，也就是在启动代理时配置的broker.id对应的值。同时与传统消息系统不同的是，Kafka并不会立即删除已被消费
RabbitMQ之消息的可靠性传递
在当今的信息化时代，消息传递在企业级应用和分布式系统中扮演着至关重要的角色。而 RabbitMQ 作为一款强大的消息队列中间件，以其可靠性和高性能成为了众多开发者的首选。本文将深入探讨 RabbitMQ 中消息的可靠性传递机制，以及如何在实际应用中确保消息的不丢失。通过阅读本文，您将了解到 Rabb
kafka客户端生产者消费者kafka可视化工具（可生产和消费消息）
因在工作中经常有用到kafka做消息的收发，每次调试过程中，经常需要查看接收的消息内容以及人为发送消息，从网上搜寻了一下，找到的工具大部分都是Kafka Tool，此工具功能还比较全面，但是操作起来个人认为并不是那么方便，于是，就萌生了自己写一个简单又好用的kafka客户端的想法。
kafka权限认证 topic权限认证 权限动态认证-亲测成功
1、Kafka的权限分类身份认证（Authentication）：对client 与服务器的连接进行身份认证，brokers和zookeeper之间的连接进行Authentication（producer 和 consumer）、其他 brokers、tools与 brokers 之间连接的认证。上
- 1
- 2
