【运维基础篇】-新版Kafka部署
Kafka在2.8版本之前，Kafka强依赖zookeeper来来负责集群元数据的管理，这也导致当Zookeeper集群性能发生抖动时，Kafka的性能也会收到很大的影响。2.8版本之后，kafka3.x开始提供KRaft（Kafka Raft，依赖Java 8+ ）模式，开始去除对zookeepe
Kafka源码分析(五) - Server端 - 基于时间轮的延时组件
Kafka源码分析，侧重于时间轮延时组件
Kafka的安装及接入SpringBoot
Kafka 是一种高性能、分布式的消息队列系统，最初由 LinkedIn 公司开发，并于2011年成为 Apache 顶级项目。它设计用于处理大规模的实时数据流，具有高吞吐量、低延迟、持久性等特点，被广泛应用于构建实时数据管道、日志收集、事件驱动架构等场景。
kafka系列一：初识kafka
kafka是由scala语言编写的一个分布式且具备高可用、高性能、可持久化、可水平扩展、支持流数据处理等众多特性的消息系统，常活跃于大数据生态中，而且大名鼎鼎的rocketmq就是参考了kafka的设计原理。目前越来越多的开源分布式中间件都支持与kafka集成（elk、spark、storm、can
RabbitMQ、RocketMQ和Kafka全面对决，谁是最佳选择？
适用于易用性和灵活性要求较高的场景异步任务处理：RabbitMQ提供可靠的消息传递机制，适用于处理异步任务，例如将耗时的任务放入消息队列中，然后由消费者异步处理，提高系统的响应速度和可伸缩性。解耦系统组件：通过使用RabbitMQ作为消息中间件，不同的系统组件可以通过消息进行解耦，实现松耦合的架构，
基于Doris的日志存储分析平台（同步Kafka日志数据）
【代码】基于Doris的日志存储分析平台（同步Kafka日志数据）
linux系统安装kafka（新版本3.7.0）
如果你需要在生产环境中使用Kafka，你可能需要考虑配置Kafka集群或者使用更高级的管理和监控工具。openjdk11下载：https://mirrors.tuna.tsinghua.edu.cn/Adoptium/11/jdk/x64/linux/注意事项：kafka会用到jdk，kafka_2
「Kafka」Kafka生产数据和消费数据（三）
把当前的DOS窗口当成Kafka的客户端，那么进行操作前，就需要连接服务器，这里的参数就表示服务器的连接方式，因为我们在本机启动Kafka服务进程，且Kafka默认端口为9092，所以此处，后面接的参数值为localhost:9092，用空格隔开。把当前的DOS窗口当成Kafka的客户端，那么进行操
Kafka
具体来说，分区 0 的副本应该存储在 Broker 1 上，分区 1 的副本应该存储在 Broker 2 上，分区 2 的副本应该存储在 Broker 0 上。请注意，使用 replica-assignment 参数需要确保指定的副本分配是有效的，即每个副本都应该分配到一个活动的 Broker 上，
【Kafka】消费者Consumer详解
一文吃透kafka消费者特性
kafka调优参考建议 —— 筑梦之路
这里主要是从不同使用场景来调优，仅供参考。
Kafka数据积压的解决方案
生产上当一个大数据流式计算程序在消费 Kafka 数据时，可能会遇到某个 topic 中的数据生产速度远远超过消费速度，导致数据积压的问题，该如何解决？
Kafka 实战 - Kafka生产者之消息发送流程及同步异步发送API
消息发送流程涉及以下几个关键步骤，同时提供同步和异步两种发送 API 供开发者选择，以适应不同场景的需求。通过理解 Kafka 生产者的消息发送流程以及同步与异步发送 API 的使用，开发者可以根据实际业务需求选择合适的发送模式，有效利用 Kafka 实现消息的高效、可靠传输。类的构造函数创建生产者
linux安装kafka3.5.2、kafka可视化管理工具kafka-ui-lite
linux安装kafka3.5.2、kafka可视化管理工具kafka-ui-lite。
Kafka客户端工具：Offset Explorer 使用指南
Kafka客户端工具：Offset Explorer 使用指南
kafka消费数据，有时消费不到原因？
7：消费者客户端启动后未消费消息：如果发现一个消费者客户端已经启动了，但是就是不消费消息，应该检查该消费者所在的组中是否还有其他的消费者。综上所述，解决Kafka消费数据不到的问题，需要从多个方面进行排查和优化，包括但不限于检查配置、调整生产与消费的速度匹配、提高消费者的处理能力、确保网络稳定以及及
Kafka学习笔记（二、linux和docker安装及使用demo）
第一个总是Kafka Connect进程的配置，包含常见的配置，比如Kafka要连接的代理和数据的序列化格式。这些示例配置文件，包含在Kafka中，使用您之前启动的默认本地集群配置并创建两个连接器:第一个是源连接器，它从输入文件中读取行并将每个行生成到Kafka主题，第二个是接收器连接器，它从Kaf
Kafka案例1-Kafka的安装
kafka/config/server.properties 中的 broker.id 及 advertised.listeners。（1）先启动zookeeper集群，然后启动kafka。（2）依次在master、slave1和slave2节点上启动kafka。3、进入到/opt/program/
Python 版分布式消息队列 Kafka 实现图片数据传输
在使用 Kafka 之前，通常需要先安装和配置 ZooKeeper。ZooKeeper 是 Kafka 的依赖项之一，它用于协调和管理 Kafka 集群的状态。ZooKeeper 是一个开源的分布式协调服务，它提供了可靠的数据存储和协调机制，用于协调分布式系统中的各个节点。Kafka 使用 ZooK
一文彻底搞懂Kafka如何保证消息不丢失
在使用消息队列时，数据不丢失是至关重要的。Kafka 作为一款主流的消息队列系统，提供了多方面的机制来保障数据不丢失，针对生产者、消费者和代理节点三个层面，是如何保证数据不丢失的
