kafka可视化工具Kafka Tool安装使用
Kafka Tool是一款 Kafka 的可视化客户端工具，可以非常方便的查看 Topic 的队列信息、消费者信息以及 kafka 节点信息。官网地址: https://www.kafkatool.com/download.html。下载对应系统架构的kafkatool包。连接成功后,查询Topic
Kafka、ActiveMQ、RabbitMQ、RocketMQ四大消息队列优劣对比与选择指南
在分布式系统架构中，消息队列（Message Queue, MQ）扮演着至关重要的角色，它作为异步通信的核心组件，能够实现系统解耦、削峰填谷、数据缓冲等功能。本文将聚焦于四大主流消息队列——Kafka、ActiveMQ、RabbitMQ、RocketMQ，深度剖析它们各自的优缺点，并在最后提供一份详
Flink CDC 整库 / 多表同步至 Kafka 方案（附源码）
我们此前介绍的一些 CDC 开箱即用方案往往都是一张表对应一条独立的链路（作业），需要一个独立的数据库连接，在表数量很大的情况下，会对数据库造成很大压力，同时过多的 Flink 作业会不易于管理和维护，为众多小表创建独立的采集作业也浪费了资源。此外，使用 Flink SQL 针对每张表定义 CDC
kafka 可视化工具
平时我们几乎都是查询topics 和 consumer 比较多，选择topics选项卡，右边就会显示kafka当前所拥有的topic，要查看某个 topic里面的消息，直接点击相应topic就能进到相应页面。删除topic，删除消费者组，查看消费者组，查询消息所属partition等等。随着科技发展
Kafka服务端高性能技术细节原理：基于零拷贝的mmap和sendfile
Kafka 的生产者将消息数据写入一个底层的 Socket 输出流中，并调用 sendfile 系统调用来将数据发送给消费者。由于 sendfile 可以直接将文件内容发送到网络输出流中，因此它避免了不必要的内存拷贝和数据复制，提高了数据传输效率。sendfile 是一个系统调用，它可以将文件内容直
Kafka之Producer网络传输
我们首先回想一下Producer消息发送的整体流程客户端线程会不断地写入数据，当前线程并不会阻塞，而是马上返回。这个时候消息被Producer放在了缓存内，消息并没有真正发送出去Producer内部为每个Partition维护了一个RecordBatch的队列，先进先出的模式，统称为RecordAc
kafka可视化工具搭建之kafdrop
Kafdrop 是一个用于查看 Kafka 主题和浏览消费者组的 Web UI。该工具显示代理、主题、分区、消费者等信息,并且可以预览topic消息。
零拷贝原理+kafka中的零拷贝
零拷贝原理+mmp优化零拷贝+sendfile优化零拷贝+kafka中的零拷贝
(Kafka源码三)Kafka的缓存机制
本文主要讲解了线程添加消息(append()方法源码)到RecordAccumulator的源码流程，以及在添加的过程中所涉及到内存的申请与释放的源码分析，最后介绍了RecordAccumulator通过CopyOnWriteMap实现的batches,从而实现了读写分离与高并发读的能力。下一章将从
docker-compose部署kafka、SASL模式(密码校验模式)
注意点：192.168.1.20 是宿主机的ip。
@KafkaListener的配置使用
【代码】spring-kafka的配置使用。
Kafka数据推送配置 | 如何设置账号密码验证？
背景：之前资产信息用网络接口进行数据推送，但是接口推送需要验证而且反应较慢。Kafak中间件提供了另一种可行的数据推送方式，它可以进行消息队列推送，且反应速度快。但是Kafka需部署在公网环境，并进行登录验证，如果部署Kafka后未设置登录验证，会被恶意扫描到，此时向Kafka里面push超过1G的
看看Kafka生产环境如何调优
通常在生产环境中，Kafka都是用来应对整个项目中最高峰的流量的。这种极高的请求流量，对任何服务都是一个很大的负担，因此如果在生产环境中部署Kafka，也可以从以下几个方面进行一些优化。
ELK+kafka日志系统
input配置：指定kafka集群个节点地址，指定topics，该topics就是在k8s集群中daemonset yml文件中引用的topics变量，指定编码为jsonoutput配置：通过type过来日志，将过滤的日志发送给elasticsearch，hosts指定elasticsearch集群
(ROOT)KAFKA详解
在RecordAccumulator中的batchs队列中的每个元素就是ProducerBatch，第一次发送消息的时候会消息所在分区的ProducerBatch队列，并创建ProducerBatch将该条消息追加在ProducerBatch，然后有新的消息发送时，就会追加消息到对应TopicPar
基于 HBase & Phoenix 构建实时数仓（5）—— 用 Kafka Connect 做实时数据同步
安装配置 Kafka connect 插件实现 MySQL 到 Hbase 的实时数据同步。
Java实战：Spring Boot集成Kafka消息中间件
本文将详细介绍如何在Spring Boot应用程序中集成Kafka消息中间件。我们将探讨Kafka的基本概念，以及如何使用Spring Boot和Kafka客户端库来实现消息的生产和消费
Kafka 和 Spring整合Kafka
Kafka是一个分布式的流媒体平台。早期只是消息队列,慢慢扩充,可以进行很多其他操作,功能很综合,因此称为一个分布式的流媒体平台应用：消息系统(核心) 日志收集 用户行为追踪 流式处理。kafka是目前来说性能最好的消息队列服务器，能处理TB级别的数据.
07 | Kafka：如何分析一个软件的实现？
今天是了解设计的第三部分：看实现。理解一个实现，是以对模型和接口的理解为前提的。每个系统的实现都有非常多的细节，我们不可能一上来就把所有的细节吃透。如果想了解一个系统的实现，应该从软件结构和关键技术两个方面着手。无论是软件结构，还是关键技术，我们都需要带着自己的问题入手，而问题的出发点就是我们对模型
Kafka
Kafka是一个分布式流式平台，它有三个关键能力订阅发布记录流，它类似于企业中的消息队列或企业消息传递系统以容错的方式存储记录流实时记录流。
