listener配置是用来绑定BrokerIP+端口地址​的，也就是只有通过绑定的地址才能够访问到该Broker。除了绑定地址之外，还可以配置该监听地址的认证协议，也就是使用该地址连接Broker时需要指定使用何种协议方式进行连接。...

kafka可以通过多个partition实现并发，但是针对单个partition，必须顺序提交。假如消息发送顺序为1,2,3，如果先提交3，会导致1,2被提交。所以不能并发执行后立即提交。...

下面是一个完整的示例，它使用Spring Cloud Stream和Kafka来创建一个简单的消息处理器和发布器：

本文梳理笔者的MQ知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。...

作者 ｜ 褚杏娟当地时间 1 月 6 日，Confluent 联合创始人兼 CEO Jay Kreps 发布公告称，Confluent 已经签署了收购 Immerok 的最终协议，但其并未公布收购金额。Immerok 是一家支持专注云上构建和运行 Apache Flink 的创企，开...

完成安装后，我们需要下载Kafka二进制文件。可以从官方网站（https://kafka.apache.org/downloads）下载最新版本的Kafka。在本文中，我们将使用Kafka 2.8.0版本。

首先，我们需要创建一个Kafka服务来管理我们的Kafka集群。可以使用Kubernetes的Service资源来定义一个Kafka服务，如下所示：

生产者创建消息。在其他基于发布与订阅的消息系统中，生产者可能被称为发布者 或 写入者。

事务是一个程序执行单元，里面的所有操作要么全部执行成功，要么全部执行失败。RocketMQ、Kafka和Pulsar都是当今业界应用十分广泛的开源消息队列（MQ）组件，笔者在工作中遇到关于MQ选型相关的内容，了解到关于“事务消息”这个...

美团官方关于对动态线程池框架的唯一产出，来自于大家基本上看过或者有印象的一篇博客。