一、broker主要配置

1.broker自身属性的配置

2.连接的zookeeper相关配置

一张图概括kafka主要脚本的用法:

一、主题管理　

主题topic的管理主要通过kafka-topics.sh这个脚本进行操作

1.创建主题

./kafka-topics.sh --create --zookeeper <host:port> --topic <topicName> --partitions <partitionsNum> --replicati

一张图来概括新的日期时间API知识点

一、日期LocalDate

1.创建日期对象

(1)of:通过指定的年月日来构建日期对象

• of (int year, int month, int day)
  • year : 年(整型 -999,999,999至999,999,999)
  • month : 月(整型 1-12)
  • day : 日(1-31)
• of (int year, Month month, int day

Collectors是stream流处理最后一个环节collect的工具类，主要用于最后对汇集数据的处理，如将流处理结果存储为某种集合类型以及对结果进行分组、筛选、计算等操作.其主要功能如下：

本节内容还是以中奖记录对象来例：

/**
 * 中奖记录
 * @author shixinke
 * @date 2019-1-25
 */
class AwardRecord {
    /**
     * 记录I

在JAVA中实现对象的排序可以使用Comparable接口，也可以使用Comparator接口．

• Comparable : 需要自己实现比较的方法compareTo，是一个内部排序器
• Comparator : 可以使用其默认的方法和lambda表达式来实现排序，是一个外部排序器，更像一个工具接口

一、Comparable接口

• 表明实现的对象是一个可排序的类

1.一个需要排序的类，需要实现Compa

一、什么是Stream类

• 原始的集合数据类似于数据的输入
• 流式处理是对输入数据进行处理
• 处理后的数据进行汇集类似于数据输出

Stream像一个流水线作业，主要分成流水线处理和最终的汇集聚合，其作用对象是集合数据

• 流式处理(stream相关方法)
• 数据汇集(collect方法)

二、Stream类主要作用

对集合数据进行以下处理：

• 查找
• 筛选过滤
• 计算
• 组合
• 排序
• 匹配

三、Stream类主要方法

• 定义一个供

一、什么是方法引用

1.什么是方法引用

• 直接访问类或者实例的已经存在的方法或者构造方法。
• 方法引用提供了一种引用而不执行方法的方式，它需要由兼容的函数式接口构成的目标类型上下文。
• 计算时，方法引用会创建函数式接口的一个实例

2.方法引用的格式

• 实例对象::方法名
• 类名::方法名

二、方法引用的形式

方法引用主要与stream流处理一起使用，实现数据的筛选过滤等

1.构造方法引用

形式为 ClassName::

一、Lambda表达式

1.什么是lambda表达式

lambda表达式是一种匿名函数表达式

2.lambda表达式语法

• 无参 : ()-> expression
• 有参 ：(parameters)-> {statement;}

/**
 * 定义一个标签tag类
 */
class Tag {
    private int tagId;
    private String tagName;
    

Java8是一个长期支持版，有很多的特性值得去学习和研究。其特性主要有：

• 1.lambda表达式
• 2.接口默认方法和静态方法
• 3.方法引用
• 4.Stream流处理
• 5.Optional
• 6.新的日期时间API

具体细节如下图：

一、Zookeeper集群环境搭建

请参考zookeeper集群搭建

二、kafka集群环境搭建

1.集群环境说明

注：以上3台服务器都是CentOS 7.x系统

2.在各节点上下载并安装kafka

wget http://mirro