kafka
-
Kafka入门(安装和SpringBoot整合)
文章目录 一、Docker安装Kafka 1. 创建网络 2. 安装zookeeper 3. 安装Kafka 二、Kafka介绍 1. Kafka简介 三、SpringBoot整合…
-
kafka（一）——简介
简介 Kafka 是一种分布式、支持分区、多副本的消息中间件，支持发布-订阅模式，多用于实时处理大量数据缓存的场景，类似于一个“缓存池”。 架构 Producer：消息生产者； C…
-
保证消息顺序性：Kafka 的策略与挑战
目录 1. 为什么消息顺序性很重要？ 2. Kafka 的消息顺序性挑战 2.1 分区与并行性 2.2 生产者与网络延迟 2.3 消费者群组 3. 保证消息顺序性的策略 3.1 单…
-
kafka乱序消费可能的原因和解决方案
Kafka乱序消费可能的原因有以下几个： 分区顺序：Kafka中的消息按照分区进行存储和分发，每个分区内的消息是有序的，但不同分区之间的消息顺序是无法保证的。如果消费者在多个分区上…
-
Springboot 配置使用 Kafka
Springboot 配置使用 Kafka 前言 一、Linux 安装 Kafka 二、构建项目 三、引入依赖 四、配置文件 生产者 yml 方式 Config 方式 消费者 ym…
-
KafkaConsuner 指定开始消费的位置
KafkaConsumer 指定消费位置的基础 一个 Topic 对应着磁盘上的几个重要的文件： .log：数据文件，存储了该 topic 中的所有消息。 .index：索引文件，…
-
docker 部署kafka
随笔记录 目录 1. 安装zookeeper 2. 安装Kafka 2.1 拉取kafka image 2.2 查询本地docker images 2.3 查看本地 容器（dock…
-
记一次docker安装kafka，zookeeper拒绝连接的问题
第一次玩kafka，在使用docker安装kafka时，出现了如下问题 kafka的启动参数KAFKA_ZOOKEEPER_CONNECT不能是localhost:2181，因为不…
-
springcloud(nacos)集成Kafka
官网：http://kafka.apache.org/ 1.kafka安装前的配置 Kafka对于zookeeper是强依赖，保存kafka相关的节点数据，所以安装Kafka…
-
基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(一)案例需求
文章目录 Flume+Kafka+Hbase+Flink+FineBI的实时综合案例 01：课程回顾 02：课程目标 03：案例需求 Flume+Kafka+Hbase+Flink…
-
Spring集成Kafka
前言 我负责的其中一个项目，接口的交互量在千万级/d，所以要存储大量的日志，为了防止日志的存储影响到系统的性能，所以在技术选型就决定了使用Kafka中间件和一个日志存储系统来负责日…
-
【项目实战】Kafka中Topic创建介绍
一、Kafka介绍 Kafka是一种分布式流处理平台，它可以处理实时数据流，支持高吞吐量、低延迟的数据处理。 它通过Topic和Partition机制将消息存储在集群中，并支持高吞…
-
【深入浅出RocketMQ原理及实战】「消息队列架构分析」帮你梳理RocketMQ或Kafka的选择理由以及二者PK
帮你梳理RocketMQ或Kafka的选择理由以及二者PK 前提背景 架构对比 RocketMQ的架构 Kafka的架构 Broker对比 主从架构模型差异: 维度不同 刷盘机制 …
-
实战：Spring Cloud Stream集成兼容多消息中间件kafka、rabbitmq
文章目录 前言 实战要点 技术积累 Spring Cloud Stream简介 集成kafka要点 集成rabbitmq要点 实战演示 Maven依赖版本号选择 Spring及MQ…
-
Flink读取kafka数据报错
报错如下： D:\software_install\java\bin\java.exe “-javaagent:C:\Program Files\JetBrains\Intelli…
