包含标签：kafka 的文章
-
SpringBoot 3.1.7 集成Kafka 3.5.0
一、背景 写这边篇文章的目的，是记录我在集成kafka客户端遇到的一些问题，文章会记录整个接入的过程，其中会遇到几个坑，如果需要最终版本，直接看最后一节……admin 2024-01-29
-
kafka-顺序消息实现
kafka-顺序消息实现 场景 在购物付款的时候，订单会有不同的订单状态，对应不同的状态事件，比如：待支付，支付成功，支付失败等等，我们会将这些消息推送…… -
kafka（一）——简介
简介 Kafka 是一种分布式、支持分区、多副本的消息中间件，支持发布-订阅模式，多用于实时处理大量数据缓存的场景，类似于一个“缓存池”。 架构 Producer…… -
Kafka-消费者-KafkaConsumer分析-SubscriptionState
KafkaConsumer从Kafka拉取消息时发送的请求是FetchRequest(具体格式后面介绍),在其中需要指定消费者希望拉取的起始消息的offset。 为了消费者快速获取这个值…… -
【Kafka每日一问】Kafka消费者故障，出现活锁问题如何解决?
在Kafka中，消费者的“活锁”通常是指消费者实例持续失败并重新加入消费者组，但却始终无法成功处理消息。这种现象可能会导致消费者组不断触发重平衡（rebalanc…… -
Kafka消费流程
Kafka消费流程 消息是如何被消费者消费掉的。其中最核心的有以下内容。 1、多线程安全问题 2、群组协调 3、分区再均衡 1.多线程安全问题 当多个线程访问某…… -
保证Kafka消息有序性
一、Kafka特性 写入同一个partion分区中的数据是一定有顺序的 kafka中一个消费者消费一个partion的数据，消费者取出数据时，也是有顺序的 二、保证消息Ka…… -
如何选择消息队列？Kafka 与 RabbitMQ
在上一期中，我们讨论了使用消息队列的好处。然后，我们回顾了消息队列产品的历史。现在看来，当我们需要在项目中使用消息队列时，Kafka 是首选产品。但是，…… -
ELK+kafka+filebeat企业内部日志分析系统搭建
看上面的拓扑图，我们至少准备七台机器进行下面的实验项目。 机器主要作用分布如下: 三台安装elasticsearch来搭建ES集群实现高可用，其他机器就依次安装file…… -
【日志系列】什么是分布式日志系统？
✔️什么是分布式日志系统？ 现在，很多应用都是集群部署的，一次请求会因为负载均衡而被路由到不同的服务器上面，这就导致一个应用的日志会分散在不同的服……