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

发表于   |   浏览(1671)   |   评论(0)

一、broker主要配置

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

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

发表于   |   浏览(97)   |   评论(0)

一张图来概括新的日期时间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工具类

发表于   |   浏览(69)   |   评论(0)

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

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

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

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

发表于   |   浏览(349)   |   评论(0)

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

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

一、Comparable接口

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

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

发表于   |   浏览(73)   |   评论(0)

一、什么是Stream类

stream流水线流程

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

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

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

二、Stream类主要作用

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

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

三、Stream类主要方法

stream知识框架

  • 定义一个供

专题 更多...

分类 更多...

展开

标签 更多...

归档 更多...

展开