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），记录着该分区的消息此时被消费的位置；一个消费线程可以对应...