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

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&...

kafka的背景知识已经讲了很多了，让我们现在开始实践吧，假设你现在没有Kafka和ZooKeeper环境。 Step 1: 下载代码 下载1.1.0版本并且解压它。 > tar -xzf kafka_2.12-2.3.0.tgz >...

消息 kafka更好的替换传统的消息系统，消息系统被用于各种场景（解耦数据生产者，缓存未处理的消息，等），与大多数消息系统比较，kafka有更好的吞吐量，内置分区，副本和故障转移，这有利于处理大规模的消息。 根据我们的经验，消息往往用于较低的吞吐...

Kafka作为一个分布式的流平台，这到底意味着什么？ 我们认为，一个流处理平台具有三个关键能力： 发布和订阅消息(流)，在这方面，它类似于一个消息队列或企业消息系统。 以容错(故障转移)的方式存储消息(流)。 在消息流发生时处理它们。 什么是ka...

你可以登录Apache kafka 官方下载。 https://kafka.apache.org/downloads.html 注意:别下成源文件了！ 带src的是源文件,如： Source download: kafka_2.11-2.3.0....