Kafka 面试题（2022）
有关kafka的面试题最新整理
Kafka为什么性能这么快？4大核心原因详解
Kafka的性能快这是大厂Java面试经常问的一个话题，下面我就重点讲解Kafka为什么性能这么快的4大核心原因@mikechen
Kafka积压造成的数据合并错误解决方式
采用两个脚本和一张hive表解决kafka数据积压而造成的影响数据合并准确性问题
kafka常见命令集锦
目标熟悉kafka各个组件的功能。熟练使用zookeeper客户端操作kafka节点，通过命令的方式验证kafka各个组件之间的关联关系。相关概念Brokerkafka节点，多个broker组成kafka集群。Topic即主题，kafka通过Topic对消息进行分类，发布到kafka的消息都需要指定
SpringBoot 集成 Kafka
SpringBoot 集成 Kafka
在Java中发送kafka消息
文章目录一、kafka API简介二、引入kafka java客户端依赖三、发送消息一、kafka API简介kafka包含5个核心api：Producer API用来让应用程序发送流数据到kafka集群中的主题。Consumer API用来让应用程序读取kafka集群主题中的流数据。Streams
Filebeat+Kafka+ELK日志采集(二)——Filebeat
Filebeat用于日志采集，将采集的日志做简单处理（多行合并）发送至Kafka、Logstash、Elasticsearch等。
Spring整合Kafka
Apache Kafka发源于LinkedIn，于2011年成为Apache的孵化项目，随后于2012年成为Apache的主要项目之一。-Kafka使用Scala和Java进行编写。Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统。Kafka具有高吞吐量、内置分区
基于WSL2在Windows 2022部署Docker应用
很多教程要装什么HyperV，其实不用，这个WSL 2就是代替原来虚拟机的，是一个正宗的Linux Container，用HyperV的叫Windows Contariner，这个可以在Docker Desktop右下角图标右击的时候切换，但我们不要切换，保持在Linux Container即WSL
Kafka详解（中）——Kafka客户端操作
3-1 shell列举 kafka安装目录下的bin目录包含了很多运维可操作的shell脚本，列举如下：脚本名称用途描述connect-distributed.sh连接kafka集群模式connect-standalone.sh连接kafka单机模式kafka-acls.sh设置Kafka权限ka
kafka日志清理
kafka日志清理
@KafkaListener详解与使用
目录1 id 监听器的id2 监听topic3 errorHandler 异常处理4 containerFactory 监听器工厂5 clientIdPrefix 客户端前缀6 concurrency并发数从2.2.4版开始，您可以直接在注释上指定Kafka使用者属性，这些属性将覆盖在使用者工厂中配
java理论知识之Kafka
Kafka 起初是由 Linkedin 公司采用 Scala 语言开发的一个多分区、多副本且基于ZooKeeper协调的分布式消息系统。 目前 Kafka 已经定位为一个分布式流式处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而被广泛使用。
grafana-普罗米修斯-监控linux-windows版
Prometheus/Process-Exporter/Grafana三件套，用于监控脚本/应用是否一直在运行，长时间运行时的性能使用情况并用可视化的图标显示出来。Prometheus（普罗米修斯）是一套比较完备的监控报警系统，其主要架构设计如图：设计架构图1. 主要是由以下组件构成：
kafka笔记4--安装kafka ui
kafka笔记4--安装kafka ui1 介绍2 安装 & 测试2.1 docker 部署 kafka-ui2.2 测试3 注意事项4 说明1 介绍文章 Overview of UI Tools for Monitoring and Management of Apache Kafka Clust
【kafka-ui】支持kafka with kraft的可视化集群管理工具
支持kafka3.3.1的kafka可视化客户端，并且可以连接带认证的kafka集群
Flink从Kafka读取数据流写入到MySQL
今天来实现一个综合案例：Flink从独立部署的Kafka读取数据流，处理后，通过自定义的Sink函数写入到MySQL中部署一个Kafka服务，源源不断的想主题kafka发送数据参考：SpringBoot整合Kafka效果Flink思路：从Kafka源源不断获取的数据为User实体的JSON字符串，需
关于kafka数据丢失场景的一次激烈讨论.... |文末送书
大家好,我是彦祖~问题描述最近彦祖发现,有不少同学 对 acks 和 min.insync.replicas 的配置存在不少误解.刚好拿一个同学的问题,来好好说明一下根据上面提的几个问题, 整理一下几个知识点acks = all的概念是什么？min.insync.replicas 是怎么用的？什么情
Flume集群安装部署、Kafka集群安装部署以及Maxwell安装部署实战
Flume集群安装部署、Kafka集群安装部署以及Maxwell安装部署实战
Kafka生产者——消息发送流程，同步、异步发送API
Kafka的Producer发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程:main线程和Sender线程，以及一个线程共享变量:RecordAccumulator。①main线程中创建了一个双端队列RecordAccumulator，将消息发送给RecordAccumulat
