@KafkaListener 注解

2022年5月6日 · 2589 字 · 6 分钟 · Kafka

一、简介Kafka 目前主要作为一个分布式的发布订阅式的消息系统使用,也是目前最流行的消息队列系统之一。本文集成的框架 spring-kafka

Kafka | 生产调优

2022年5月6日 · 7608 字 · 16 分钟 · Kafka

一、Kafka 硬件配置选择1.1、场景说明100 万日活,每人每天 100 条日志,每天总共的日志条数是 100 万 * 100 条 = 1 亿条。 1 亿 / 24 小时 / 60 分 / 60 秒 =

Kafka | 消费者

2022年5月6日 · 7287 字 · 15 分钟 · Kafka

一、Kafka 消费方式pull(拉)模式: consumer 采用从 broker 中主动拉取数据。 Kafka 采用这种方式。 push(推)模式: Kafka 没有采用这种方式,因为由 broker 决定消息

Kafka | Broker

2022年5月6日 · 5698 字 · 12 分钟 · Kafka

一、Kafka Broker 工作流程1.1、Zookeeper 存储的 Kafka 信息(1)启动 Zookeeper 客户端。 bin/zkCli.sh (2)通过 ls 命令可以查看 kafka 相关信息。 ls /kafka Zookeeper 中存储的 Kafka 信息

Kafka | 生产者

2022年5月6日 · 4979 字 · 10 分钟 · Kafka

一、生产者消息发送流程1.1、发送原理在消息发送的过程中,涉及到了两个线程:main 线程 和 Sender 线程。在 main 线程中创建了一个双端队列 RecordA

Kafka | 概述 & 安装部署

2022年5月6日 · 2767 字 · 6 分钟 · Kafka

一、概述1.1、定义Kafka 传统定义:Kafka 是一个分布式的基于发布/订阅模式的消息队列 Message Queue,主要应用于大数据实时处理领域。 Kafka 最

kubernetes | Dashboard-2.1.0 部署

2022年3月17日 · 1079 字 · 3 分钟 · Kubernetes

一、简介Dashboard 是基于网页的 Kubernetes 用户界面。可以使用 Dashboard 将容器应用部署到 Kubernetes 集群中,也可以对容器应用排错,还能管理集群本身及其附属资源。您

kubernetes | Helm 简介

2022年3月17日 · 2430 字 · 5 分钟 · Kubernetes

一、Helm 引入K8S 上的应用对象,都是由特定的资源描述组成,包括 deployment、service 等。都保存各自文件中或者集中写到一个配

kubernetes | Ingress

2022年3月17日 · 3909 字 · 8 分钟 · Kubernetes

一、引言在 Kubernetes 中,Ingress 是一种 API 对象,用于管理外部访问集群服务的方式,通常是 HTTP 和 HTTPS 流量。可以将 Ingress 理解为一个智能的路由器,它根据请求的 URL

kubernetes | 一次性任务与定时任务

2022年3月17日 · 1139 字 · 3 分钟 · Kubernetes

一、Job 一次性任务概述主要负责批处理任务,Job 创建一个或多个 Pod,并确保指定数量的 Pod 成功终止。Pod 成功完成后,Job 将跟踪成功完成的