@KafkaListener 注解
2022年5月6日 · 2589 字 · 6 分钟 · Kafka
一、简介Kafka 目前主要作为一个分布式的发布订阅式的消息系统使用,也是目前最流行的消息队列系统之一。本文集成的框架 spring-kafka
2022年5月6日 · 2589 字 · 6 分钟 · Kafka
一、简介Kafka 目前主要作为一个分布式的发布订阅式的消息系统使用,也是目前最流行的消息队列系统之一。本文集成的框架 spring-kafka
2022年5月6日 · 7608 字 · 16 分钟 · Kafka
一、Kafka 硬件配置选择1.1、场景说明100 万日活,每人每天 100 条日志,每天总共的日志条数是 100 万 * 100 条 = 1 亿条。 1 亿 / 24 小时 / 60 分 / 60 秒 =
2022年5月6日 · 7287 字 · 15 分钟 · Kafka
一、Kafka 消费方式pull(拉)模式: consumer 采用从 broker 中主动拉取数据。 Kafka 采用这种方式。 push(推)模式: 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 信息
2022年5月6日 · 4979 字 · 10 分钟 · Kafka
一、生产者消息发送流程1.1、发送原理在消息发送的过程中,涉及到了两个线程:main 线程 和 Sender 线程。在 main 线程中创建了一个双端队列 RecordA
2022年5月6日 · 2767 字 · 6 分钟 · Kafka
一、概述1.1、定义Kafka 传统定义:Kafka 是一个分布式的基于发布/订阅模式的消息队列 Message Queue,主要应用于大数据实时处理领域。 Kafka 最
2022年3月17日 · 1079 字 · 3 分钟 · Kubernetes
一、简介Dashboard 是基于网页的 Kubernetes 用户界面。可以使用 Dashboard 将容器应用部署到 Kubernetes 集群中,也可以对容器应用排错,还能管理集群本身及其附属资源。您
2022年3月17日 · 2430 字 · 5 分钟 · Kubernetes
一、Helm 引入K8S 上的应用对象,都是由特定的资源描述组成,包括 deployment、service 等。都保存各自文件中或者集中写到一个配
2022年3月17日 · 3909 字 · 8 分钟 · Kubernetes
一、引言在 Kubernetes 中,Ingress 是一种 API 对象,用于管理外部访问集群服务的方式,通常是 HTTP 和 HTTPS 流量。可以将 Ingress 理解为一个智能的路由器,它根据请求的 URL
2022年3月17日 · 1139 字 · 3 分钟 · Kubernetes
一、Job 一次性任务概述主要负责批处理任务,Job 创建一个或多个 Pod,并确保指定数量的 Pod 成功终止。Pod 成功完成后,Job 将跟踪成功完成的