Kafka 下载安装及使用总结
Kafka 下载安装及使用总结
Kafka-Eagle 监控 搭建
Kafka-Eagle 框架可以监控 Kafka 集群的整体运行情况，在生产环境中经常使用。在生产过程中，想创建topic、查看所有topic、想查看某个topic 想查看分区等，都需要写命令，能不能有一个图形化的界面，让我们操作呢？
Spring Boot 集成 Kafka
本文介绍了如何在 Spring Boot 项目中集成 Kafka，包括 Kafka 的基本概念、Spring Boot 集成 Kafka 的步骤、配置项以及实际应用案例。通过集成 Kafka，我们可以构建出高效、可靠的消息驱动应用，实现系统之间的异步通信和解耦。
详解kafka消息发送重试机制的案例
在 Kafka 生产者中实现消息发送的重试机制，可以通过配置 KafkaProducer 的相关属性来实现。以下是一些关键的配置项：retries：设置生产者发送失败后重试的次数。retry.backoff.ms：设置生产者在重试前等待的时间。buffer.memory：设置生产者在内存中缓存数据的
Kafka+RabbitMQ+ActiveMQ看看消息队列设计精要12
消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发的Notify、MetaQ、Rocke
Kafka+RabbitMQ+ActiveMQ看看消息队列设计精要2
消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发的Notify、MetaQ、Rocke
【Kafka】与【Hadoop】的集成应用案例深度解析
本文深入探讨了Kafka与Hadoop两大大数据处理技术的集成应用案例。首先，文章概述了Kafka作为分布式流处理平台的优势，包括其高吞吐量、低延迟以及强大的容错能力，这些特性使其成为处理实时数据流的首选工具。接着，文章介绍了Hadoop生态系统，强调了其在批处理大数据集方面的卓越性能和广泛应用的组
【kafka】大数据编写kafka命令使用脚本，轻巧简洁实用kafka
这个脚本提供了一个用户友好的界面，整合了常见的 Kafka 操作功能，包括主题操作、生产者操作、消费者操作、配置操作、消费者组操作以及生产者和消费者的性能测试。通过简单的数字选择，用户可以轻松地进入相应的操作菜单，执行所需的命令，大大提高了操作效率。
大数据面试题--kafka夺命连环问（前15问）
kafka面试题
kafka和Flume的整合
在窗口不断的发送文本数据，数据被抽取到了kafka中，如何获取kafka数据呢？启动一个消息生产者，向topic中发送消息，启动flume,接收消息。
kafka+zookeeper的搭建
kafka+zookeeper的配置
面试题：消息积压怎么解决？RocketMQ与Kafka有哪些区别？Kafka性能优于RocketMQ的原因？
RocketMQ和Kafka在数据可靠性、消费失败重试、分布式事务消息、Broker端消息过滤、消息顺序性以及适用场景等方面也存在显著差异。消息积压是消息中间件中常见的问题，尤其是在高并发、大数据量的场景下。RocketMQ通过一系列机制来应对消息积压问题
大数据技术Kafka详解 ① | 消息队列（Messages Queue）
大数据技术Kafka详解 ① | 消息队列
Docker安装zookeeper(zookeeper-latest)与Kafka(kafka-latest)
-e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://123.60.133.141:9092 这个IP一定要是外网IP，不要设置为内网IP。# KAFKA_ADVERTISED_HOST_NAME当前主机IP或地址（重点：如果是服务器部署则配服务器IP或域名否则
Docker Compose部署Kafka（非Zookeeper）
整个工具的代码都在Gitee或者Github地址内。
Kafka的心跳处理机制用到了时间轮算法
现在正是金三银四的春招高潮，前阵子小编一直在搭建自己的网站，并整理了全套的**【一线互联网大厂Java核心面试题库+解析】：包括Java基础、异常、集合、并发编程、JVM、Spring全家桶、MyBatis、Redis、数据库、中间件MQ、Dubbo、Linux、Tomcat、ZooKeeper、N
kafka消费端常见故障及处理方法
kafka消费端经常会出现一些故障，一起来分析一下故障原因以及解决方法。
Kafka 源码 KRaft 模式本地运行
通过使用 Raft 协议直接在 Kafka 内部管理元数据，旨在消除对 ZooKeeper 的依赖，从而简化架构，提高性能和可靠性。特点和优势如下：- 简化架构：没有了 ZooKeeper，Kafka 集群的部署和管理变得更简单。- 提高性能：去除了与 ZooKeeper 的交互，减少了延迟，提高了
最全Kafka知识宝典之生产者深度剖析
我们有以下需求，根据key进行分区，如果为空或者不以数字结尾则分配到0分区，否则，拿结尾的数字与分区数求余/*** 自定义分区：根据key进行分区，如果为空或者不以数字结尾则分配到0分区，否则，拿结尾的数字与分区数求余*/@Override@Overridereturn 0;n = n < 0?re
kafka之视频和图片文件
在 Kafka 中存储视频或图片的格式通常取决于应用场景和传输的需求。Kafka 是一种分布式的流处理平台，设计用来处理事件流或消息流，。
