-- 统计当前目录下有多少个文件和文件夹ls | wc -l不要用    ll | wc -l或者    find | wc -l因为都会比真实文件数多一个，亲测列出当前目录下的所有文件 (以-开头的都是文件)ll | grep ^-同样列出当前目录下的所有子目录ll | grep ^d只统

前期条件，已经创建好注册中心，如果没有，请看上一篇http://blog.csdn.net/hcmony/article/details/77855158。一，创建服务消费者springcloud项目创建参考http://blog.csdn.net/hcmony/article/details/77855158创建方式和创建eureka工程一样，相比于服务提供者，多了一个feign1,pox.xm

简述Environment创建ProjectNewProject - Maven填写GroupIdArtifactId选择存储位置创建结果修改结果创建第一个module 注册中心 EurekaNew Module Spring选择CloudDiscovery - Eureka ServerProject的pom和module的pom的对比提取公共依赖后对比启动前启动Last简述SpringClou

1 什么是CDH，ambari？ Ambari是Apache软件基金顶级项目，它是一个基于web的工具，用于安装、配置、管理和监视Apache Hadoop集群，支持Hadoop HDFS,、Hadoop MapReduce、Hive、HCatalog,、HBase、ZooKeeper、Oozie、Pig和Sqoop。Ambari同样还提供了集群状况仪表盘，比如heatmaps和查看Map...

JSONObject对同一个key重新put时，新值就会取代旧值，没有set之类的方法构建json string时，所有的引号都要转义package xx;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;// 对JSONObject中的指定字段重新赋值public class testJ...

Kafka 0.9版本开始推出了Java版本的consumer，优化了coordinator的设计以及摆脱了对zookeeper的依赖。社区最近也在探讨正式用这套consumer API替换Scala版本的consumer的计划。鉴于目前这方面的资料并不是很多，本文将尝试给出一个利用KafkaConsumer编写的多线程消费者实例，希望对大家有所帮助。    这套API最重要的入口就是KafkaC

原文地址 https://blog.csdn.net/xianpanjia4616/article/details/82534369上一篇中我们在本地跑了一个wordcount,今天我们写一个流式的计算wordcount,读取kafka的数据进行实时的计算,把结果写入redis中;pom文件如下:<dependency>            <group

原文地址https://www.jianshu.com/p/c148bf91c3ac2019.05.26由于近期在研究ELK和最新的实时计算框架Flink，所以把以前热力图项目flume+kafka+SparkStreaming+mysql+ssm+高德地图热力图项目换组件重构一下。效果不会变好，可能更麻烦，性能更低，纯属应用一下最近研究的新组件和新计算框架。项目环境：fileb...

生产用的kafka都是在linux上搭建集群，为了在本地快速学习kafka，可以搭建一个单机版的windows环境，我下载的是0.9版本安装很简单，基本就是下载之后解压就可以了，但是在安装kafka之前要先安装zookeeper，单机版的zookeeper也很好安装，下载之后解压就可以了试验时要启动zookeeper，然后再启动kafka下面是windows cmd操作kafka的常用命令进入ka

设置消费者properties的两个参数consumer.group.idproperties.setProperty("auto.offset.reset", "earliest”) // latest注意：只要不更改group.id，每次重新消费kafka，都是从上次消费结束的地方继续开始，不论"auto.offset.reset”属性设置的是什么场景一：Kafka上...