官方定义k8s能够对容器化软件进行部署管理，在不停机的前提下提供简单快速的发布和更新方式。如果你们的项目使用多机器节点的微服务架构，并且采用Docker image（镜像）进行容器化部署，那么就可以使用k8s。一个k8s集群由一个master和多个worker节点组成。Master 负责管理集群 负责协调集群中的所有活动，例如调度应用程序，维护应用程序的状态，扩展和更新应用程序。Worker节点(

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

利用Spring boot开发Restful 接口1：Spring boot1.1：SpringBoot框架SpringBoot框架一般分为View层、Controller层、Service层、Mapper层、pojo层。View层：视图层，根据接到的数据展示页面给用户Controller层：响应用户需求，决定用什么视图，需要准备什么数据来显示。Controller层负责前后端交互，接收前端请求，