1. 需要依赖的jar包<!--分页插件 --><dependency><groupId>com.github.pagehelper</groupId><artifactId>pa

本人在采集kafka数据时，对于不标准的报文转成标准json形式采用了MassageFormat类定义标准模板进行处理，在java.text包中的 Fomart 接口是所有处理格式的基础接口，有三个子类：DateFormat、MessageFormat、NumberFormat。MessageFormat 是专门处理文本格式的类，且没有子类。MessageFormat 中的参数说明：{ A...

阅读官网文档很有必要http://kafka.apache.org/documentation.html分区、Offset、消费线程、group.id的关系一组（类）消息通常由某个topic来归类，我们可以把这组消息“分发”给若干个分区（partition），每个分区的消息各不相同；每个分区都维护着他自己的偏移量（Offset），记录着该分区的消息此时被消费的位置；一个消费线程可以对应...

springboot使用的是2.0.0版本，spring-kafka使用的是2.1.4版本，配置的时候遇到了一些问题，在此总结一下：1. session-timeout连接超时时间，之前 配置的是3000(ms)，一直报异常，堆栈信息提示连接超时时间不能大于“某时间”，这里一直没弄懂“某时间”是指哪个时间。ps:忘记“ ”里的时间是什么了，可能是我英语太差的原因。2. 是否开启自动提交...