1：简介Kibana 是一款开源的数据分析和可视化平台，它是 Elastic Stack 成员之一，设计用于和 Elasticsearch 协作。您可以使用 Kibana 对 Elasticsearch 索引中的数据进行搜索、查看、交互操作。您可以很方便的利用图表、表格及地图对数据进行多元化的分析和呈现。2：安装2.1 安装1：下载方式1：linux执行拉取linux直接下载：wget https

1：安装dockerdocker安装以及使用安装成功后docker verion检查是否安装成功1：启动docker systemctl start docker2：检查docker运行状态systemctl status docker3：利用docker部署nigex2：linux部署nigexNginx相关地址源码：https://trac.nginx.org/nginx/browser官网：

1：安装dockerdocker安装以及使用安装成功后docker verion检查是否安装成功1：启动docker systemctl start docker2：检查docker运行状态systemctl status docker3：利用docker部署nigex2：linux部署nigexNginx相关地址源码：https://trac.nginx.org/nginx/browser官网：

1：安装dockerdocker安装以及使用安装成功后docker verion检查是否安装成功1：启动docker systemctl start docker2：检查docker运行状态systemctl status docker3：利用docker部署nigex2：linux部署nigexNginx相关地址源码：https://trac.nginx.org/nginx/browser官网：

kafka偏移量管理基本概念spark streaming 的偏移量管理offset 管理

kafka的压力测试压力测试都是针对整个集群的，如果想测试单节点的性能，可以创建topic指定分区都在同一节点进行测试1：生产者压测kafka-topics-perf-test.sh --topic test --num-records 100000 --record-size 1000 --throughput -1 --producer.config ../config/producer.pr

废话少说，直接上总结。1：KafkaProducer类，详细源码解析见：作用：用于发送数据而提供的kafka 客户端，进行发送数据前的，集群连接配置，网络连接配置，用于向RecordAccumulator写数据。2：RecordAccumulator消息累加器，用于数据缓存，内存管理3：Sender独立于KafkaProducer的线程，负责发送RecordAccumulator数据前的准备工作，

1：java的map转scala的map//java的map转为scala的immutable.mapprivate static scala.collection.immutable.Map<String,String> JavaMapToScala(Map kafkaparams) {Map<String, String> javamap ...

Error running 'JsonSchemaTest.loadSchemaTestFailed':Command line is too long. Shorten command line for。。。。。 also for JUnit default configuration? (a minute ago)命令太长加载时找不到在configuration中选择modify option