前言 开源社区有好多优秀的队列中间件，比如RabbitMQ和Kafka，每个队列都貌似有其特性，在进行工程选择时，往往眼花缭乱，不知所措。对于RabbitMQ和Kafka，到底应该选哪个？ RabbitMQ架构 RabbitMQ是一个分布式系统，...

标题上红牛标志预示着它并不简单 先说下单例模式，由于频繁创建对象比较浪费资源，就考虑将所有用到某个类的实例时，公用同一个实例，于是就有了单例模式。 单例模式写法有很多，于是我看到了这么一种写法： public class SingletonTe...

前提：所有实验操作是基于mysql5.6，其他版本可能有差异，届时以具体的情况为准。 1、where后面的条件字段需添加索引，避免全表扫描。 2、连表查询时，关联字段需建立索引，并且应该保证关联字段的类型一致，避免类型转换。如： SELECT *...

如何保证消息的可靠性传输？或者说，如何处理消息丢失的问题？ 面试题 如何保证消息的可靠性传输？ 或者说，如何处理消息丢失的问题？ 面试官心理分析 这个是肯定的，用 MQ 有个基本原则，就是数据不能多一条，也不能少一条，不能多，就是前面说的重复消费...

第一回 陌生警察我出生在 C 盘下面一个很深层次的目录下， 也不知道是谁把我放到这里的。 我一直在睡觉，外边的日出日落，风雨雷电和我一点关系都没有。 直到有一天，有个家伙咣咣咣砸我房门把我叫醒。 这个家伙穿着像警察的制服， 左手拿着一个对讲机， ...

我的博客即将同步至腾讯云+社区，邀请大家一同入驻：https://cloud.tencent.com/developer/support-plan?invite_code=bdrcqt081z2a

1.group.id 消费者所属消费组的唯一标识 2.max.poll.records 一次拉取请求的最大消息数，默认500条 3.max.poll.interval.ms 指定拉取消息线程最长空闲时间，默认300000ms 4.session....

ProducerConfig类 buffer.memory 重要性：高 类型：Long 默认值：33554432字节，即32M producer可以用于缓存等待发送到服务端的消息记录的缓冲区大小，当消息记录发送到缓冲区的速度大于传输到server...

本文章中针对的是kafka-clients 1.1.0版本。 ProducerConfig 类在包org.apache.kafka.clients.producer中。 ProducerConfig各配置项 bootstrap.servers 重...

直接开始吧 首先maven引入jar包 <!-- kafka --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId&...