首页
动态
橙Bot
导航
翻译橙
标签分类
文章归档
专栏
图库
友链
留言板
1
我在青岛~
2
搞懂spring事务机制,这篇文章就够了!
3
深入掌握JDK流处理机制:高效操作集合的秘密,全在这里!
4
熟用AI,可以带来哪些提效?
5
一文读懂流处理和批处理
橙序员
累计撰写
182
篇文章
累计创建
64
个标签
累计收到
4
条评论
栏目
首页
动态
橙Bot
导航
翻译橙
标签分类
文章归档
专栏
图库
友链
留言板
搜索
标签搜索
事务
流处理
大数据
旅行
mongo db
SUNO
github
IDEA
安全
注解
总结
求职
分布式事务
CAP
分布式系统
loadbalancer
装修
买房
前端
方案设计
AIGC
JVM
资讯
Netty
NIO
BIO
zookeeper
RocketMQ
MySQL
stable diffusion
spring MVC
spring AOP
JDBC
mybatis
logback
docker
consul
spring event
新冠
连接池
redis
运维
nginx
hiper-v
DDD
搞笑
数据库
团建
游戏
Gradle
心情
好物
eureka
spring framework
spring boot
设计模式
apache common
ShardingSphere
KAFKA
leetcode
spring cloud
feign
ES
起点
目 录
CONTENT
以下是
KAFKA
相关的文章
2024-01-14
为什么要有事务消息?
事务消息是为了解决消息发送失败导致数据不一致的问题而提出的。在一个场景中,当我们创建订单时,需要通知库存系统和出货系统同时更新库存和出货消息。如果消息中间件挂掉或消息发送失败,订单系统、库存系统和出货系统的数据将无法保持一致性。为了解决这个问题,可以借助分布式事务的思路,将本地事务执行和消息发送看作两个分支事务,通过创建一个事务协调器来保证它们的原子性。在这个流程中,事务协调器作为消息中间件的一部分,能够保证订单系统在下单过程中生产的所有消息都在一个事务里。然而,事务协调器无法知道每个生产者会产生什么消息,只能将事务id绑定到生产者维度,导致只能保证一次发送多条事务消息的一致性。因此,基于这种实现的事务消息机制只能保证多条事务消息的一致性,但会扩大事务的范围,导致其他消息不能及时被消费者监听。需要注意的是,在这个场景中,订单的生产者还会发送其他消息,如通知用户充值、收货等消息,这些消息也会受到事务消息机制的限制。
2024-01-14
405
0
0
开发技巧
2023-07-23
中间件是如何进行集群管理的?
常用的中间件进行集群管理的方式有两种:一种是通过注册中心进行集群管理的:中间件注册中心redissentinelrocket MQname serverkafkazookeeperdubbozookeeperspring boot(微服务)eureka,consul,Nacos另一种是通过分布式节点
2023-07-23
449
0
0
开发技巧
2023-07-22
Kafka内部构成解析
ZookeeperKafka 通过 zookeeper 来存储集群的meta元数据信息。Zookeeper负责维护和协调broker,负责Broker Controller的选举。BrokerKafka集群中的每⼀台服务器。一个broker上有多个partition组成。当每个 broker 启动时
2023-07-22
347
0
0
开发技巧
2022-09-09
kafka分区策略
日常使用kafka时,在发送消息和消费消息的时候经常会有两个困惑:kafka如何把我们发送者的消息均匀的分发到不同的topic和partition上的?在消费时,又是怎么将这些partition中的消息均匀的分发到我们不同的消费者上的?为了解决这两个问题,kafka在生产和消费时通过实现了各种不同的
2022-09-09
546
0
0
开发技巧
2022-08-21
【译文】spring kafka简介及使用参考(四)
4.2. 非阻塞重试这是一项实验性功能,在删除实验性名称之前,不破坏 API 更改的常规规则不适用于此功能。鼓励用户尝试该功能并通过 GitHub 问题或 GitHub 讨论提供反馈。这仅与 API 有关;该功能被认为是完整且健壮的。2.9 版更改了引导基础设施 bean 的机制;请参阅配置以了解现
2022-08-21
1599
0
0
文档翻译
2022-08-21
【译文】spring kafka简介及使用参考(三)
本文介绍了Apache Kafka的序列化、反序列化和消息转换。Kafka提供了高级API,用于处理记录值和键的序列化和反序列化。可以通过配置属性或使用重载构造函数来指定序列化器和反序列化器类。对于复杂或特定的情况,可以使用KafkaConsumer和KafkaProducer的重载构造函数来指定键和值的序列化器和反序列化器实例。DefaultKafkaProducerFactory和DefaultKafkaConsumerFactory还提供属性,可以将自定义的序列化器和反序列化器实例注入到目标Producer或Consumer中。同时,可以使用Supplier实例来创建每个Producer或Consumer时调用的序列化器和反序列化器。从2.5版本开始,Spring for Apache Kafka还提供了ToStringSerializer和ParseStringSerializer,用于字符串序列化。以上是本文的主要内容。
2022-08-21
1796
0
1
文档翻译
2022-08-21
【译文】spring kafka 简介及使用参考(二)
本内容是关于侦听器容器属性的描述。其中包括了ackCount、adviceChain、ackMode、ackTime、assignmentCommitOption、authExceptionRetryInterval、clientId、checkDeserExWhenKeyNull、checkDeserExWhenValueNull、commitCallback等属性的默认值和描述。对于每个属性,都给出了默认值和相应的描述。
2022-08-21
1791
0
0
文档翻译
2022-08-21
【译文】spring kafka 简介及使用参考(一)
本文介绍了Spring for Apache Kafka项目,该项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。该项目提供了发送消息的高级抽象的\模板\,并支持消息驱动的POJO。文中还提到了使用该项目的先决条件,包括安装并运行Apache Kafka,并将spring-kafka JAR及其依赖项添加到类路径中。对于使用Spring Boot的情况,可以省略版本声明,Boot会自动引入与Boot版本兼容的正确版本。最快的入门方法是使用start.spring.io创建一个项目,选择\Spring for Apache Kafka\作为依赖项。本文还说明了该项目的兼容性和最低Java版本要求。
2022-08-21
1729
0
1
文档翻译
2022-07-27
KAFKA 简单介绍
能力介绍三个概念1、发布和订阅消息,相当于一个消息队列2、以容错的方式存储消息3、在消息产生时进行处理四个核心API:producer API: 发布消息到topic中consumer API:消费topic中的消息streams API:产生输出流到topic,并将输入流转换到输出流。可以用作流处
2022-07-27
539
0
0
开发技巧
2022-07-27
KAFKA 生产者&消费者配置详解
生产者配置详解属性名称描述类型默认值有效值重要性bootstrap.servershost/port列表,用于初始化建立和Kafka集群的连接。列表格式为host1:port1,host2:port2,…,无需添加所有的集群地址,kafka会根据提供的地址发现其他的地址(你可以多提供几个,以防提供的
2022-07-27
571
0
0
开发技巧