【中间件】通过 docker-compose 快速部署 Kafka 保姆级教程
Kafka是由Apache基金会开发的分布式流处理平台，采用发布-订阅模式，支持高吞吐量、低延迟的数据传输。主要用于处理实时数据管道、数据存储和数据分析等大数据应用场景。Kafka采用高效的数据压缩算法，可以在集群中存储大量的数据，并通过分区机制来实现数据的高可靠性和可扩展性。数据管道：在数据采集和
kafka和rabbitmq之间的区别以及适用场景
Kafka 和 RabbitMQ 都是强大的消息传递系统，具有不同的特点和适用场景。Kafka 适合处理大规模的实时数据流、日志收集和流式处理，适用于实时性要求较高的场景；而 RabbitMQ 适用于异步通信、任务分发、RPC 和事件驱动等场景，提供更多的消息传递模式选择。在选择使用哪种系统时，应根
Kafka消息消费流程详解
Kafka消费者的流程可以概括为以下几个步骤：创建Kafka消费者实例；订阅一个或多个主题；拉取消息记录；处理消息；提交消费位移；控制消费速率；错误处理和重试；关闭消费者。下面将详细介绍每个步骤及其相关代码。
kafka自动退出问题：开启kafka一段时间后，jps发现kafka自动退出。
kafka自动关闭退出问题：开启kafka一段时间后，jps发现kafka自动退出
4.3、Flink任务怎样读取Kafka中的数据
flink1.17 读取kafka 数据
Kafka分区消息积压排查指南
如果指定了消息key，那么消息会指定生产到hash(key)的分区中。消息生产是否指定key？
超简洁步骤安装kafka（linux环境）
4、在zookeeper的conf目录下修改配置文件名（启动zookeeper的时候会去找zoo.cfg）4、在config目录下修改配置文件server.properties。2、通过rz命令将zookeeper安装包上传到linux。一、查看jdk是否安装（如果没有安装，可自行百度安装）5、在z
Kafka入门，手动提交offset，同步提交，异步提交，指定 Offset 消费（二十三）
Kafka入门，手动提交offset，同步提交，异步提交，指定 Offset 消费（二十三）
Window下安装Kafka
可以选择 源代码 下载，也可以选择 Scala版本 进行下载。这里博主选择 Scala .13 版本进行下载。下载速度很慢，维持在10kb/s，推荐找个镜像网站下载。注意：Kafka安装文件中包含zookeeper。格式文件兼容Windows系统，可以正常运行。进行路径的修改，选择自己适合的路径即可
kafka---- zookeeper集群搭建
zkServer.sh start-foreground 使用它启动会出现地址已在使用。Zookeeper启动失败（java.net.BindException: 地址已在使用。如果只是使用zkServer.sh stop会停不干净，后续继续研究，方法在上。端口被占用了，把2181端口改成别的就可
Kerberos安全认证-连载12-Kafka Kerberos安全配置及访问
技术连载系列，前面内容请参考前面连载11内容:Kafka也支持通过Kerberos进行认证，避免非法用户操作读取Kafka中的数据，对Kafka进行Kerberos认证可以按照如下步骤实现。在kerberos服务端node1节点执行如下命令将Kafka服务主体写入到key
Kafka基本使用
查看Kafka的进程是否在运行。
flink消费kafka数据，按照指定时间开始消费
kafka中根据时间戳开始消费数据。
Kafka 源码编译部署包
Java 版本: 1.7.0_80。Gradle 版本: 4.8.1。Kafka 版本: 0.11。
Kafka消息丢失：原因、解决方案和零丢失的配置
Kafka消息丢失是一个常见的问题，但通过合理的配置和实施解决方案，可以降低消息丢失的风险。本文介绍了Kafka消息丢失的原因、解决方案以及实现零丢失的配置方法。通过正确配置生产者和消费者、增加副本因子、监控和警报系统，以及合理的容量规划，我们可以实现高可靠性的消息传递系统。
Kafka中的 ISR 机制
ISR 机制的存在是 kafka 为了平衡可靠性和可用性，不指定提供高可靠或者高可用的服务，而是将决定权交给了使用者，让使用者通过参数来控制，到底要实现什么程度的高可靠与高可用。
kafka消费报错卡死：内存溢出OutOfMemoryError: Java heap space
【代码】kafka消费报错卡死：内存溢出OutOfMemoryError: Java heap space。
干货 | 成本低误差小，携程基于 Kafka 的 Serverless 延迟队列的实践
作者简介Pin，关注 RPC、Service Mesh、Serverless 等云原生技术。一、背景随着上云项目的不断推进，大量的应用需要部署到 aws 上，其中有很多应用都依赖延迟队列的功能。而在aws上，我们选择以 Kafka 作为消息队列，但是 Kafka 本身不支持延迟队列，这就需要思考如何
kafka第一课-Kafka快速实战以及基本原理详解
1、Topic是一个逻辑概念，Producer和Consumer通过Topic进行业务沟通。 2、Topic并不存储数据，Topic下的数据分为多组Partition，尽量平均的分散到各个Broker上。每组Partition包含Topic下一部分的消息。每组Partition包含一个Lead
liunx服务器安装kafka
要启动 ZooKeeper，您需要一个配置文件。下载文件名含bin的压缩包，要不然启动报错。，官网包下载地址，具体命令操作参考官网。查看kafka 支持的最低jdk版本。下载对应 的zookeeper 版本，：下载kafka src 源文件。具体的jdk版本 看kafka。) ，解压打开相对路径的
