java8全新的日期和时间API LocalDate、LocalTime、LocalDateTime是java8对日期、时间提供的新接口。实际使...
应用场景 前两天我们已经介绍了两种Spring Cloud Stream对消息失败的处理策略: 自动重试[https://www.jianshu...
在使用消息队列开发Spring cloud stream项目时,连接rabbitmq遇到一个问题: 问题1:连接报错信息 com.rabbitm...
简述在声明式的事务处理中,要配置一个切面,其中就用到了propagation,表示打算对这些方法怎么使用事务,是用还是不用,其中propagat...
在新发布的kafka2.8.0版本中,已经可以不启动zk就可以使用kafka了,在config目录下多了一个kraft目录,在该目录中有一套新的...
从上一章节我们总结了相关概念,其实在kafka架构图中可以直观的看到这些相关的概念,具体如下图: 从上图中我们先来分析相关概念: Produce...
消息(Message):kafka的数据单元,相当于数据库里面的一个数据行或一条记录。消息由字节数组组成,所以对于Kafka 来说,消息里的数据...
kafka概述 从官网的介绍来看,Kafka是一个分布式的消息订阅系统,它主要有3种功能:1、It lets you publish and s...
自定义的错误处理 自定义错误一般是对于知道要发生什么错误,对于错误消息的一个处理方式,该方式适合在业务上有特殊处理的消息错误,比如错误数据保存到...