java kafka中broker、producer、consumer主要配置参数说明

一、broker主要配置

1.broker自身属性的配置
配置项 作用 类型 默认值 示例
broker.id broker在集群中的标识  整型 -1 1
listeners 监听的服务地址(多个用,隔开) String null PLAINTEXT://myhost:9092
2.连接的zookeeper相关配置
配置项 作用 类型 默认值 示例
zookeep

java Java8新特性(6).新的日期时间API

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

新的日期时间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

java Java8新特性(5).Stream流处理收集器Collectors工具类

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

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

  1. /**
  2. * 中奖记录
  3. * @author shixinke
  4. * @date 2019-1-25
  5. */
  6. class AwardRecord {
  7. /**
  8. * 记录I

java Java8新特性(4).java比较和排序接口之比较器Comparator和比较接口Comparable

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

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

一、Comparable接口

  • 表明实现的对象是一个可排序的类
1.一个需要排序的类,需要实现Compa

java Java8新特性(3).Stream流处理

一、什么是Stream类

stream流水线流程

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

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

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

二、Stream类主要作用

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

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

三、Stream类主要方法

stream知识框架

  • 定义一个供