为了帮助企业更有效地推进数字化转型升级，袋鼠云精心策划了一系列以“数字基建+数智应用”为核心的赋能分享活动，本系列直播共有四期，每期聚焦于不同的关键议题，深入探讨企业数字化转型中面临的挑战以及可行的应对策略。我们期待通过这些直播活动，与业界同仁深化交流，共同探...
数栈君 发表于2025-01-14 23:19
177
0
一、参考阿里云的官方链接：使用Python SDK接入Kafka收发消息_云消息队列 Kafka 版(Kafka)-阿里云帮助中心二、安装python环境 三、添加python依赖库pip install confluent-kafka==1.9.2四、新建...
数栈君 发表于2025-01-14 16:40
151
0
Flink中的批和流批处理的特点是有界、持久、大量，非常适合需要访问全部记录才能完成的计算工作，一般用于离线统计。流处理的特点是无界、实时, 无需针对整个数据集执行操作，而是对通过系统 传输的每个数据项执行操作，一般用于实时统计。一个无界流可以分解为多个有界流...
数栈君 发表于2025-01-14 15:28
164
0
一.持久化我们在前⾯讲了消费端处理消息时,消息如何不丢失,但是如何保证当RabbitMQ服务停掉以后,⽣产者发送的消息不丢失呢.默认情况下, RabbitMQ 退出或者由于某种原因崩溃时,会忽视队列和消息,除⾮告知他不要这么做.它确保消息在消息队列崩溃、重启或...
数栈君 发表于2025-01-14 15:09
189
0
一、Kafka1、什么是消息队列假设我们有两个服务：生产者A每秒能生产200个消息，消费者B每秒能消费100个消息。那么B服务是处理不了A这么多消息的，那么怎么使B不被压垮的同时还能处理A的消息呢，我们引入一个中间件，即Kafka。（当然着并不能使消费者的处理...
数栈君 发表于2025-01-14 14:32
155
0
消息队列（如RabbitMQ、Kafka）的使用与原理。消息队列是一种分布式系统中的设计模式，它允许系统中的不同组件通过异步的方式交换信息。以下是RabbitMQ和Kafka这两种消息队列的使用与原理的详细介绍：一、消息队列的基本概念消息队列的核心概念是将发送...
数栈君 发表于2025-01-14 14:16
251
0
如何解决MQ的重复消费问题？MQ（消息队列）的重复消费问题是一个需要认真对待的挑战，因为它可能导致业务逻辑的重复执行，进而引发数据不一致或其他问题。以下是一些常见的解决MQ重复消费问题的方法：一、确保消息幂等性消费者幂等设计：设计消费者时，应确保其具有幂等性，...
数栈君 发表于2025-01-14 14:08
256
0
《数据资产管理白皮书》下载地址：https://www.dtstack.com/resources/1073/?src=bbs《行业指标体系白皮书》下载地址：https://www.dtstack.com/resources/1057/?src=bbs《数据治...
数栈君 发表于2025-01-13 16:58
165
0
Kafka 是一款高吞吐量、低延迟的分布式消息系统。本文将详细介绍如何在 Spring Boot 项目中使用 Kafka 进行消息接收与消费，并结合幂等和重试机制，确保消息消费的可靠性和系统的扩展性。我们将以电商交易系统为案例进行深入解析。1. 系统架构概览在...
数栈君 发表于2025-01-10 10:30
292
0
章节内容上节我们完成了如下的内容：·自定义拦截器(续接上节) 编写代码·日志采集小结整体结构ODS层ODS的定义ODS是一种面向操作层的数据存储，专注于支持企业的日常运营。它通常整合了来自不同数据源（如ERP、CRM、销售系统等）的数据，通过清洗、转换后存储，...
数栈君 发表于2025-01-10 10:11
252
0
@Copyrights 2016-2023 杭州玳数科技有限公司 浙ICP备15044486号-1 浙公网安备33011002011932号
