【文章推荐】Spring-Kafka —— KafkaListener手动启动和停止

Spring-Kafka —— KafkaListener定时启动和停止

一、定时启动的应用场景比如现在单机环境下，我们需要利用Kafka做数据持久化的功能，由于用户活跃的时间为早上10点至晚上12点，那在这个时间段做一个大数据量的持久化可能会影响数据库性能导致用户体验降低，我们可以选择在用户活跃度低的时间段去做持久化的操作，也就是晚上12点后到 ...

Spring-Kafka —— KafkaListener禁止自启动

应用服务启动时，KafkaListener默认会自动启动进行消费，如果想不自动消费，可以设置AutoStartup属性值为false 完整消费代码vk ...

spring-kafka手动提交offset

消费者监听类实现AcknowledgingMessageListener这个监听器，可以实现手动提交offset： ...

spring-kafka之KafkaListener注解深入解读

讲述的spring-kafka框架的kafkaListener注解的深入解读和使用案例。解读源码解读 ...

Spring-Kafka —— 实现批量消费和手动提交offset

spring-kafka的官方文档介绍，可以知道自1.1版本之后， @KafkaListener开始支持批量消费，只需要设置batchListener参数为true 把application.yml中的enable-auto-commit设置为false,设置为不自动提交 ...

Spring-Kafka —— AckMode介绍和手动提交分析总结

前言本文主要讲述一下spring for kafka的consumer在spring.kafka.consumer.enable-auto-commit是false情况下，AckMode的选项，及手动提交分析总结。 AckMode Manual Commit ...

Spring-Kafka —— 实现批量消费和手动提交offset

spring-kafka的官方文档介绍，可以知道自1.1版本之后， @KafkaListener开始支持批量消费，只需要设置batchListener参数为true 把application.yml中的enable-auto-commit设置为false,设置为不自动提交 ...

spring-kafka1.3.3（对应kafka-clients版本0.11.0.0，请使用于kafk ...