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是一个分布式流式平台，它有三个关键能力订阅发布记录流，它类似于企业中的消息队列或企业消息传递系统以容错的方式存储记录流实时记录流。
kafka安全机制（SASL_SCRAM）
zookeeper和kafka在默认情况下，是没有开启安全认证的，那么任意客户端可以在不需要任何身份认证的情况下访问zookeeper和kafka下的各节点，甚至可以进行节点的增加，修改以及删除的动作。除了最基本的身份认证以外，还有针对每个节点的权限访问，但本文不涉及该话题。如果是集群模式，那么只需
上海天翼云代理商：分布式消息服务Kafka高吞吐、高可用的消息中间件服务
Kafka是一个分布式发布-订阅消息系统，它最初由LinkedIn公司开发，后来成为Apache项目的一部分。Kafka分布式特性强，可以处理TB级数据，支持和许多主流语言进行交互，包括JAVA,Python等。由于Kafka的这些显著优点，它在大数据处理、实时计算以及日志收集等领域都表现出色。开创
Kafka入门到实战-第五弹
Apache Kafka 是一个开源的分布式事件流平台，提供高性能数据管道、流分析、 数据集成和任务关键型应用程序。
