本篇文档使用kafka版本为：0.9.0.0 问题1、在现场项目中，kafka连接正常一直无数据？ 1）通常是确认配置是否正确，包含任务配置，ip端口号； 2）查看topic offset：是否有新数据进来，数据是否被消费掉了， 3）然后检查kafka服务是否正常，查看服务是否有节点 ...

启用spring-kafka 在spring boot 配置类上添加 配置kafka 在application.properties中添加配置 生产者 消费者者 项目中使用 ...

启动kafka正常 1.创建一个spring boot项目 2.配置使用kafka 引入依赖（gradle） implementation 'org.springframework.kafka:spring-kafka' 添加配置文件（全部使用java配置 ...

JAVA 8 Spring Boot 2.5.3 Elasticsearch-7.14.0（Windows） --- 授人以渔： 1、Spring Boot Reference Documentation This document is also available ...

最近一段时间一直在学习Spring Boot，刚进的一家公司也正好有用到这个技术。虽然一直在学习，但是还没有好好的总结，今天周末先简单总结一下基础知识，等有时间再慢慢学习总结吧。 Spring Boot 概述 首先，Spring Boot是一个框架，主要理念就是消除项目中大量的配置文件，使项目 ...

准备工作： 1.安装kafka+zookeeper环境 2.利用命令创建好topic 参考官网 http://kafka.apache.org/documentation/ 一XML配置文件方式实现 🌟1. Pom文件,引入spring-kafka jar包这里需要注意2个地方 ...

一. 回顾 producer->topic->consumer 集群运行，每个服务broker tcp协议，Kafka提供java端，另一端可支持多种语言 topic topic是对一组消息的归纳，每个topic分区 每个分区都有个offset consumer需要维护 ...

场景： kafka先批量拉取消息，完了将拉下来的消息逐条消费，假如此次共拉取40条消息，但在处理第31条时，线程被停掉，就会导致已消费消息offet不会被提交，接下来已经被消费的30条记录还会被重复消费，这就是kafka重复消费的另一场景； 解决思路： 解决此类重复消费的方式：将能够唯一标识 ...