kafka
-
Kafka 命令行操作
版本：3.6.1 1 kafka-topics.sh Create, delete, describe, or change a topic. 创建、删除、描述或更改主题。 Opt…
-
【Kafka】Kafka介绍、架构和概念
目录 Kafka介绍 Kafka优势 Kafka应用场景 Kafka基本架构和概念 Producer Consumer/Consumer Group Broker ZooKeepe…
-
kafka学习笔记– 文件清理策略与高效读写数据
本文内容来自尚硅谷B站公开教学视频，仅做个人总结、学习、复习使用，任何对此文章的引用，应当说明源出处为尚硅谷，不得用于商业用途。 如有侵权、联系速删 视频教程链接：【尚硅谷】Kaf…
-
kafka丢数据的原因
目录 背景 kafkaClient代码 消息丢失的可能原因 `broker is down` `RD_KAFKA_MSG_SIZE_TOO_LARGE` 分区问题 Kafka Br…
-
【flink番外篇】20、DataStream 和 Table集成-Changelog Streams变化流示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点，并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
实战：彻底搞定 SpringBoot 整合 Kafka
前言 kafka是一个消息队列产品，基于Topic partitions的设计，能达到非常高的消息发送处理性能。Spring创建了一个项目Spring-kafka，封装了Apach…
-
Kafka消息阻塞：拯救面试的八大终极解决方案！
大家好，我是小米，一个对技术充满热情的90后程序员。最近在准备社招面试的过程中，遇到了一个超级有挑战性的问题：“Kafka消息阻塞怎么解决？”今天，我就来和大家一起深入剖析这个问题…
-
Kafka（七）可靠性
目录 1 可靠的数据传递 1.1 Kafka的可靠性保证 1.2 复制 1.3 Broker配置 1.3.1 复制系数 1.3.2 broker的位置分布 1.3.3 不彻底的首领…
-
大数据篇Kafka消息队列指定Topic打印Key、Value、Offset和Partition
1、概念简介 说到Apache Kafka消息传递系统时，以下是一些关键概念的解释： Key（键）：Kafka消息由Key和Value组成。Key是一个可选的字段，它通常用于消息的…
-
kafka启用SASL认证后使用kafka-consumer-groups.sh查看消费组报错的问题
解决SASL认证类型kafka在使用kafka-consumer-groups.sh查看消费组数据时，报以下异常的问题 Error: Executing consumer grou…
-
Kafka: 详解、使用教程和示例
Kafka: 详细介绍、使用教程和示例 什么是 Kafka？ Kafka 是一个分布式的流处理平台，最初由 LinkedIn 开发，现已成为 Apache 基金会的顶级项目。它以高…
-
分布式消息服务kafka
分布式消息队列DMS 什么是消息中间件？ 消息中间件是分布式系统中重要的组件，本质就是一个具有接收消息、存储消息、分发消息的队列，应用程序通过读写队列消息来通信。 例如：在淘宝购物…
-
【运维】Kafka高可用： KRaft（不依赖zookeeper）集群搭建
文章目录 一. kafka kraft 集群介绍 1. KRaft架构 2. Controller 服务器 3. Process Roles 4. Quorum Voters 5….
-
【Kafka-3.x-教程】-【六】Kafka 外部系统集成 【Flume、Flink、SpringBoot、Spark】
【Kafka-3.x-教程】专栏： 【Kafka-3.x-教程】-【一】Kafka 概述、Kafka 快速入门 【Kafka-3.x-教程】-【二】Kafka-生产者-Produc…
-
基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(二)数据源
文章目录 04：数据源 05：技术架构及技术选型 06：Flume的回顾及安装 07：Flume采集程序开发 04：数据源 目标：了解数据源的格式及实现模拟数据的生成 路径 ste…
