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

一、broker主要配置

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

消息系统 使用kafka的脚本对kafka进行操作

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

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

一、主题管理 

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

1.创建主题

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

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知识框架

  • 定义一个供

java Java8新特性(2).方法引用

一、什么是方法引用

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

二、方法引用的形式

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

1.构造方法引用

形式为 ClassName::

java 一张图说明JAVA8的新特性

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

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

具体细节如下图:

java8新特性

消息系统 kafka集群环境搭建

kafka集群环境搭建

一、Zookeeper集群环境搭建

请参考zookeeper集群搭建

二、kafka集群环境搭建

1.集群环境说明
ID IP 端口
1 192.168.0.200 9092
2 192.168.0.201 9092
3 192.168.0.202 9092

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

2.在各节点上下载并安装kafka
  1. wget http://mirro