kafka
-
【flink番外篇】9、Flink Table API 支持的操作示例(11)- Group Windows(tumbling、sliding和session)操作
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
一线大厂面试真题-Kafka如何保证消息不丢失
目录 问题解答 面试点评 问题解答 (如图)kafka是一个用来实现异步消息通信的中间件,它的整个架构由Producer、Consumer、Broker组成。 所以,对于kafka…
-
【Kafka系列 02】Kafka 线上集群部署方案
前言 Kafka线上集群部署方案怎么做?既然是集群部署,那必然就要有多个 Kafka 节点机器,且需要仔细地考量各种因素,结合自身的业务需求而制定。下面分别从操作系统、磁盘、磁盘容…
-
Kafka入门及可视化界面推荐
Kafka 官方文档: https://kafka.apache.org/documentation/ Kafka 中文文档 – ApacheCN 快速开始 vim c…
-
【SpringBoot】在Springboot中怎么设置Kafka自动创建Topic
我们在开发过程中使用Kafka会遇到topic太多,自己创建太费劲,所以想一次配置终身使用,自己去创建topic,和flyway一样自己去创建表,今天总结一下配置方式。 1.app…
-
吊炸天的 Kafka 图形化工具 Eagle,必须推荐给你
Kafka是当下非常流行的消息中间件,据官网透露,已有成千上万的公司在使用它。最近实践了一波Kafka,确实很好很强大。今天我们来从三个方面学习下Kafka:Kafaka在Linu…
-
kafka 如何保证消息的顺序消费
在Kafka分布式集群中,要保证消息的顺序消费,您可以采取以下措施: 分区策略:Kafka的主题可以分为多个分区,每个分区内的消息是有序的。因此,首先要确保生产者将相关的消息发送到…
-
「Kafka」生产者篇
「Kafka」生产者篇 生产者发送消息流程 在消息发送的过程中,涉及到了 两个线程 ——main 线程和Sender 线程。 在 main 线程中创建了 一个 双端队列 Recor…
-
【shell-10】shell实现的各种kafka脚本
kafka-shell工具 背景 日志 log 一.启动kafka->(start-kafka) 二.停止kafka->(stop-kafka) 三.创建topic-&…
-
Kafka可视化利器 KafkaTool 发送kafka消息
kafak是我们工作中常用的消息组件,今天在跟合作方联调的时候被告知上游没有准备好消息数据,没有办法从依赖方拿到消息但是我们还又想测试自己写的消息消费的代码,怎么办呢?常规的做法就…
-
Kafka篇——Kafka集群Controller、Rebalance和HW的详细介绍,保姆级教程!
Controller 一、概念 在Kafka中,Controller是Kafka集群中的一个角色,负责管理集群的元数据、分区分配、副本管理等功能。 Controller的主要职责包…
-
kafka高吞吐、低延时、高性能的实现原理
作者:源码时代-Raymon老师 Kafka的高吞吐、低延时、高性能的实现原理 Kafka是大数据领域无处不在的消息中间件,目前广泛使用在企业内部的实时数据管道,并帮助企业构建自己…
-
Kafka – 监控工具 Kafka Eagle:实时洞察Kafka集群的利器
文章目录 引言 Kafka Eagle简介 Kafka Eagle的特点 Kafka Eagle的优势 使用Kafka Eagle的步骤 结论 引言 在现代大数据架构中,Apach…
-
消息队列黄金三剑客:RabbitMQ、RocketMQ和Kafka全面对决,谁是最佳选择?
1、应用场景 1.RabbitMQ: 适用于易用性和灵活性要求较高的场景 异步任务处理:RabbitMQ提供可靠的消息传递机制,适用于处理异步任务,例如将耗时的任务放入消息队列中,…
-
Kubernetes 部署 Kafka 集群
docker-compose 部署 kafka 镜像地址 kafka官网 kafka镜像 zookeeper镜像Kafka 4.0 将移除zookeeper,仅支持KRaft 所以…
