昨天，有位56年工作经验的粉丝面试被问到，什么是消息中间件。平时只关注使用，并没有去总结过，竟然被这个问题住了。今天，我给大家来聊一聊。

近日，EMQX 开源版 v4.3.17、v4.3.18、v4.4.6、v4.4.7，与企业版 v4.3.12、v4.3.13、v4.4.6、v4.4.7 八个维护版本正式发布。

一位工作了5年的小伙伴去美团面试以后，跟我反馈说，被问到一个“如何保证Kafka消息不丢失？”的问题，不知道如何回答。其实，这道题真的很基础。...

创建集群 --> 新增 Topic --> 编写生产者逻辑 --> 编写消费者逻辑

下载最新版的kafkahttps://kafka.apache.org/downloads解压缩并且进入bin文件夹配置注意把51XGUCSWRJmzyJK4rU3GRg用生成的uuid替换掉默认的配置文件在config/kraft里，需要的话请修改./kafka-storage.sh random-uuid./...

使用Filebeat收集本地日志数据，Filebeat监视日志目录或特定的日志文件，再发送到消息队列到kafka，然后logstash去获取消费，利用filter功能过滤分析，最终存储到elasticsearch中。...

kafka运维常用查询操作总结以下几点：kafka生产和消费消息测试发送：bin/kafka-console-producer.sh --broker-list 10.46.200.165:9092 --topic contentApprove接收：bin/kafka-console-consumer.sh --......

现在的社会是一个高速发展的社会，科技发达，信息流通，人们之间的交流越来越密切，生活也越来越方便，大数据就是这个高科技时代的产物。大数据并不在“大”，而在于“有用”。价值含量、挖掘成本比数量更为重要。因此对大数据的...

OutOfMemoryError 问题相信很多朋友都遇到过，相对于常见的业务异常（数组越界、空指针等）来说这类问题是很难定位和解决的。

比如最近就有个这样的需求，我作为客户端要向 kafka生产数据，而 kafka的消费者则再源源不断的消费数据，并将消费的数据全部请求到 web服务器，虽说做了负载(有4台 web服务器)但业务数据的量也是巨大的，每秒钟可能有上万条数...