kafka

kafka

Java中消息队列——ActiveMQ、RabbitMQ、RocketMQ、Kafka

网友分享数栈君 发表了文章 • 0 个评论 • 206 次浏览 • 2025-01-20 14:12 • 来自相关话题

消息队列(Message Queue, MQ)是一种在分布式系统中用于异步通信的技术。Java中常用的消息队列包括ActiveMQ、RabbitMQ、RocketMQ和Kafka。本文将详细介绍它们的基本概念、工作原理、应用场景以及使用代码示例,帮助您在实际开... ...查看全部

Spring Boot 集成 Kafka

网友分享数栈君 发表了文章 • 0 个评论 • 131 次浏览 • 2025-01-17 10:41 • 来自相关话题

在现代软件开发中,分布式系统和微服务架构越来越受到关注。为了实现系统之间的异步通信和解耦,消息队列成为了一种重要的技术手段。Kafka 作为一种高性能、分布式的消息队列系统,被广泛应用于各种场景。而 Spring Boot 作为一种流行的 Java 开发框架,... ...查看全部

【Kafka】与【Hadoop】的集成应用案例深度解析

网友分享数栈君 发表了文章 • 0 个评论 • 238 次浏览 • 2025-01-17 10:25 • 来自相关话题

一、引言1、Kafka简介Apache Kafka 是一个分布式流处理平台,最初由 LinkedIn 开发,并于 2011 年开源,现在由 Apache Software Foundation 进行维护。Kafka 旨在提供一个统一、高吞吐量、低延迟的平台,用... ...查看全部

Kafka 和 RabbitMQ用哪个?一篇文章告诉你他们的区别

网友分享数栈君 发表了文章 • 0 个评论 • 193 次浏览 • 2025-01-16 10:48 • 来自相关话题

一、消息的顺序有这样一个需求:当订单状态变化的时候,把订单状态变化的消息发送给所有关心订单变化的系统。订单会有创建成功、待付款、已支付、已发货的状态,状态之间是单向流动的。好,现在我们把订单状态变化消息要发送给所有关心订单状态的系统上去,实现方式就是用消息队列... ...查看全部

python操作kafka

网友分享数栈君 发表了文章 • 0 个评论 • 146 次浏览 • 2025-01-14 16:40 • 来自相关话题

一、参考阿里云的官方链接:使用Python SDK接入Kafka收发消息_云消息队列 Kafka 版(Kafka)-阿里云帮助中心二、安装python环境 三、添加python依赖库pip install confluent-kafka==1.9.2四、新建... ...查看全部

Flink 从入门到实战

网友分享数栈君 发表了文章 • 0 个评论 • 154 次浏览 • 2025-01-14 15:28 • 来自相关话题

Flink中的批和流批处理的特点是有界、持久、大量,非常适合需要访问全部记录才能完成的计算工作,一般用于离线统计。流处理的特点是无界、实时, 无需针对整个数据集执行操作,而是对通过系统 传输的每个数据项执行操作,一般用于实时统计。一个无界流可以分解为多个有界流... ...查看全部

【Rabbitmq篇】RabbitMQ⾼级特性----持久性,发送⽅确认,重试机制

网友分享数栈君 发表了文章 • 0 个评论 • 184 次浏览 • 2025-01-14 15:09 • 来自相关话题

一.持久化我们在前⾯讲了消费端处理消息时,消息如何不丢失,但是如何保证当RabbitMQ服务停掉以后,⽣产者发送的消息不丢失呢.默认情况下, RabbitMQ 退出或者由于某种原因崩溃时,会忽视队列和消息,除⾮告知他不要这么做.它确保消息在消息队列崩溃、重启或... ...查看全部

Kafka学习-Java使用Kafka

网友分享数栈君 发表了文章 • 0 个评论 • 151 次浏览 • 2025-01-14 14:32 • 来自相关话题

一、Kafka1、什么是消息队列假设我们有两个服务:生产者A每秒能生产200个消息,消费者B每秒能消费100个消息。那么B服务是处理不了A这么多消息的,那么怎么使B不被压垮的同时还能处理A的消息呢,我们引入一个中间件,即Kafka。(当然着并不能使消费者的处理... ...查看全部

消息队列(如RabbitMQ、Kafka)的使用与原理。缓存系统(如Redis、Memcached)的使用与优化

网友分享数栈君 发表了文章 • 0 个评论 • 247 次浏览 • 2025-01-14 14:16 • 来自相关话题

消息队列(如RabbitMQ、Kafka)的使用与原理。消息队列是一种分布式系统中的设计模式,它允许系统中的不同组件通过异步的方式交换信息。以下是RabbitMQ和Kafka这两种消息队列的使用与原理的详细介绍:一、消息队列的基本概念消息队列的核心概念是将发送... ...查看全部

如何解决MQ的重复消费问题?Kafka、ActiveMQ、RabbitMQ有什么区别?

网友分享数栈君 发表了文章 • 0 个评论 • 246 次浏览 • 2025-01-14 14:08 • 来自相关话题

如何解决MQ的重复消费问题?MQ(消息队列)的重复消费问题是一个需要认真对待的挑战,因为它可能导致业务逻辑的重复执行,进而引发数据不一致或其他问题。以下是一些常见的解决MQ重复消费问题的方法:一、确保消息幂等性消费者幂等设计:设计消费者时,应确保其具有幂等性,... ...查看全部

咨询一个问题,flinksql脚本模式 kafka berberos认证 ,这样配置有问题吗

ChunJun群内解答 回复了问题 • 1 人关注 • 1 个回复 • 1126 次浏览 • 2022-12-08 14:29 • 来自相关话题

flinksql 事件时间怎么定义, kafka 的json中 ts字段是毫秒时间戳

回复

Taier匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 750 次浏览 • 2023-02-14 14:46 • 来自相关话题

咨询一个问题,flinksql脚本模式 kafka berberos认证 ,这样配置有问题吗

回复

ChunJun群内解答 回复了问题 • 1 人关注 • 1 个回复 • 1126 次浏览 • 2022-12-08 14:29 • 来自相关话题

Java中消息队列——ActiveMQ、RabbitMQ、RocketMQ、Kafka

网友分享数栈君 发表了文章 • 0 个评论 • 206 次浏览 • 2025-01-20 14:12 • 来自相关话题

消息队列(Message Queue, MQ)是一种在分布式系统中用于异步通信的技术。Java中常用的消息队列包括ActiveMQ、RabbitMQ、RocketMQ和Kafka。本文将详细介绍它们的基本概念、工作原理、应用场景以及使用代码示例,帮助您在实际开... ...查看全部

Spring Boot 集成 Kafka

网友分享数栈君 发表了文章 • 0 个评论 • 131 次浏览 • 2025-01-17 10:41 • 来自相关话题

在现代软件开发中,分布式系统和微服务架构越来越受到关注。为了实现系统之间的异步通信和解耦,消息队列成为了一种重要的技术手段。Kafka 作为一种高性能、分布式的消息队列系统,被广泛应用于各种场景。而 Spring Boot 作为一种流行的 Java 开发框架,... ...查看全部

【Kafka】与【Hadoop】的集成应用案例深度解析

网友分享数栈君 发表了文章 • 0 个评论 • 238 次浏览 • 2025-01-17 10:25 • 来自相关话题

一、引言1、Kafka简介Apache Kafka 是一个分布式流处理平台,最初由 LinkedIn 开发,并于 2011 年开源,现在由 Apache Software Foundation 进行维护。Kafka 旨在提供一个统一、高吞吐量、低延迟的平台,用... ...查看全部

Kafka 和 RabbitMQ用哪个?一篇文章告诉你他们的区别

网友分享数栈君 发表了文章 • 0 个评论 • 193 次浏览 • 2025-01-16 10:48 • 来自相关话题

一、消息的顺序有这样一个需求:当订单状态变化的时候,把订单状态变化的消息发送给所有关心订单变化的系统。订单会有创建成功、待付款、已支付、已发货的状态,状态之间是单向流动的。好,现在我们把订单状态变化消息要发送给所有关心订单状态的系统上去,实现方式就是用消息队列... ...查看全部

python操作kafka

网友分享数栈君 发表了文章 • 0 个评论 • 146 次浏览 • 2025-01-14 16:40 • 来自相关话题

一、参考阿里云的官方链接:使用Python SDK接入Kafka收发消息_云消息队列 Kafka 版(Kafka)-阿里云帮助中心二、安装python环境 三、添加python依赖库pip install confluent-kafka==1.9.2四、新建... ...查看全部

Flink 从入门到实战

网友分享数栈君 发表了文章 • 0 个评论 • 154 次浏览 • 2025-01-14 15:28 • 来自相关话题

Flink中的批和流批处理的特点是有界、持久、大量,非常适合需要访问全部记录才能完成的计算工作,一般用于离线统计。流处理的特点是无界、实时, 无需针对整个数据集执行操作,而是对通过系统 传输的每个数据项执行操作,一般用于实时统计。一个无界流可以分解为多个有界流... ...查看全部

【Rabbitmq篇】RabbitMQ⾼级特性----持久性,发送⽅确认,重试机制

网友分享数栈君 发表了文章 • 0 个评论 • 184 次浏览 • 2025-01-14 15:09 • 来自相关话题

一.持久化我们在前⾯讲了消费端处理消息时,消息如何不丢失,但是如何保证当RabbitMQ服务停掉以后,⽣产者发送的消息不丢失呢.默认情况下, RabbitMQ 退出或者由于某种原因崩溃时,会忽视队列和消息,除⾮告知他不要这么做.它确保消息在消息队列崩溃、重启或... ...查看全部

Kafka学习-Java使用Kafka

网友分享数栈君 发表了文章 • 0 个评论 • 151 次浏览 • 2025-01-14 14:32 • 来自相关话题

一、Kafka1、什么是消息队列假设我们有两个服务:生产者A每秒能生产200个消息,消费者B每秒能消费100个消息。那么B服务是处理不了A这么多消息的,那么怎么使B不被压垮的同时还能处理A的消息呢,我们引入一个中间件,即Kafka。(当然着并不能使消费者的处理... ...查看全部

消息队列(如RabbitMQ、Kafka)的使用与原理。缓存系统(如Redis、Memcached)的使用与优化

网友分享数栈君 发表了文章 • 0 个评论 • 247 次浏览 • 2025-01-14 14:16 • 来自相关话题

消息队列(如RabbitMQ、Kafka)的使用与原理。消息队列是一种分布式系统中的设计模式,它允许系统中的不同组件通过异步的方式交换信息。以下是RabbitMQ和Kafka这两种消息队列的使用与原理的详细介绍:一、消息队列的基本概念消息队列的核心概念是将发送... ...查看全部

如何解决MQ的重复消费问题?Kafka、ActiveMQ、RabbitMQ有什么区别?

网友分享数栈君 发表了文章 • 0 个评论 • 246 次浏览 • 2025-01-14 14:08 • 来自相关话题

如何解决MQ的重复消费问题?MQ(消息队列)的重复消费问题是一个需要认真对待的挑战,因为它可能导致业务逻辑的重复执行,进而引发数据不一致或其他问题。以下是一些常见的解决MQ重复消费问题的方法:一、确保消息幂等性消费者幂等设计:设计消费者时,应确保其具有幂等性,... ...查看全部