Spring Kafka（五）@KafkaListener的花式操作
1. 消息监听 对于Kafka中Topic的数据消费，我们一般都选择使用消息监听器进行消费，怎么把消息监听器玩出花来呢，那就得看看它所实现的功能了。 Spring-Kafka中消息监听大致分为两种 ...
花费 15 ms
Spring-Kafka（三）-KafkaTemplate发送消息及结果回调
我们使用KafkaTemplate.send(String data)这个方法发送消息到Kafka中，显然这个方法并不能满足我们系统的需求，那我们需要查看一下KafkaTemplate所实现的接口，看 ...
Spring Kafka（四）使用Kafka事务的两种方式
为什么要使用Kafka事务 在日常开发中，数据库的事务几乎是必须用到的，事务回滚不一定在于数据增删改异常，可能系统出现特定逻辑判断的时候也需要进行数据回滚，Kafka亦是如此， 我们并不希望消息监 ...
spring-kafka_配置参数
参考： https://blog.csdn.net/fenglibing/article/details/82117166 https://www.cnblogs.com/yx88 ...
Spring Kafka（8）配置消息过滤器
消息过滤器 消息过滤器可以在消息抵达监听容器前被拦截，过滤器根据系统业务逻辑去筛选出需要的数据再交由KafkaListener处理。 配置消息其实是非常简单的额，只需要为监听容器工厂配置一个Rec ...
Spring Kafka（9）ConsumerAwareErrorHandler异常处理器
异常处理 代码异常十之八九，十段代码九个bug，哈哈哈哈。 平常程序异常我们使用try catch捕获异常，在catch方法中根据异常类型进行相关处理， 既然我们可以使用try catch处理异 ...
Spring Kafka（六） 实现消息转发以及ReplyTemplate
目的 软件需要使用什么技术都是按照业务逻辑来的嘛，那自动转发相对应的业务可以是什么呢？ 可以使用转发功能实现业务解耦，系统A从Topic-A中获取到消息，进行处理后转发到Topic-B中，系统B监 ...
spring-kafka-消费者
一个消费者组有一个或者多个消费者如果一个消费者组订阅了主题，那么这个主题中的某个分区只能分配给消费者组中的某个消费者，不能分配给多个消费者。当1个消费者，6个分区时，将读取6个分区中的数据。当3个消费 ...
Spring Kafka（二）操作Topic以及Kafka Tool 2的使用
1. 为什么要手动创建Topic 我们从到到尾都没有创建过"topic.quick.demo"这个Topic，这是因为KafkaTemplate在发送的时候就已经帮我们完成了创建的操作 ，所以我们 ...
Spring Kafka（7）KafkaListener定时启动（禁止自启动）
定时启动的意义何在 如果只学习技术不讨论其应用范围那就是在耍流氓啊，为了不做那个流氓，我还是牺牲一下色相吧$_$ 在这里我举一个定时启动的应用场景： 比如现在单机环境下，我们需要利用Kafka做 ...