SpringBoot整合kafka后设置offset自动提交为false不起作用
2019-03-07 15:57
375 查看
首先要明确一点,当SpringBoot整合kafka后,
kafka.consumer.enable.auto.commit=false 意思是让spring自动去提交offset
kafka.consumer.enable.auto.commit=true 意识是让kafka去自动提交offset
解决办法:
在kafkaconsumer的配置类里加入以下即可:
相关文章推荐
- 关于SpringKafka消费者的几个监听器:[一次处理单条消息和一次处理一批消息]以及[自动提交offset和手动提交offset]
- centos7安装kafka单机版,并Springboot整合kafka运行
- springboot与myabitis的整合,以及自动生成mapper
- Spring Boot2 + Mybatis 整合(Mybatis自动生成插件、分页插件)
- Hibernate 自动提交autoCommit一般建议设置成false
- Spring Boot整合mybatis并自动生成mapper和实体实例解析
- centos7安装kafka(伪)集群版,并Springboot整合kafka运行
- Springboot + shiro 整合之Url拦截设置
- SpringBoot整合Kafka和Storm
- springboot 整合 MyBatis 使用generator自动生成代码
- Spring Boot 构建应用——整合消息中间件 Kafka
- Spring Boot整合Kafka的简单用例(@KafkaListener注解)
- SpringBoot实战(十四)之整合KafKa
- springboot整合kafka
- SpringMvc Dao jdbcTemplate设置不自动提交(手动提交)(适用商品抢购等事务)
- Hibernate 自动提交autoCommit一般建议设置成false
- spring和hibernate整合时设置自动生成数据库的表
- spring-boot整合redis作为缓存(1)——redis的设置
- springboot多模块化整合mybatis,出现mapper自动注入失败问题
- Spring Boot 整合Thymeleaf 之表单提交 问题