centos7 系统上面安装rabbitmq-server服务器，这里使用了一个3.7.6的版本来匹配 erlang的 20.3版本，暂时配置好环境后，是可以使用的！

1.连接Kafka并向Kafka发送模拟数据 2.连接Hbase并向其发送模拟数据 3.Kafka及Hbase相关配置均可自行配置，提供Hbase相关核心方法，有需要可自行调用 4.可通过浏览器直接触发模拟数据 5.提供Mysql及JPA连接配置，便于后续拓展

csv-kafka-json 一个简单的程序，将CSV文件作为JSON编码的消息发送到Kafka。 每行都作为单独的消息发送。 用法 在运行应用程序之前，请确保更改以主类编写的配置。

SpringBoot2.x整合Kafka实现消息中间件的发送及消费监听业务，其序列化方式采用ProtoBuf协议实现跨平台、跨语言的数据传输方式。

linux各种组件搭建

环境搭建+kafka+flink

wifi 基于flume+kafka+HBase+spark+ElasticSearch的用户轨迹查询大数据开发项目 项目名称：实时的用户轨迹查询项目 项目介绍：     利用企业建设的WIFI基站，实时采集用户的信息，可以基于这些信息做用户画像处理，网络安全监控，精准营销等； 项目架构： 主要是基于Flume+Kafka+Sparkstreaming +HBase+ES来实现实时的用户信息存储轨迹查询任务。 具体的项目说明请看文档：项目介绍 每个部分的数据运行结果以及集群的运行状况见结果文件ProjectResult！！！

KafkaOffsetMonitor-assembly-0.5.0-SNAPSHOT.jar kafka2.x版本的监控，升级了原来代码只能监控0.9x版本的问题

在KafkaOffsetMonitor 0.4.6的基础上增加： - 支持Apache Kafka 2.6.0，升级了GroupMetadataManager支持最新版本的消息协议 - 修复了无法获取broker列表的bug - 将javascipt资源和css资源全部内嵌到项目中，方便在内网进行监控

官方离线安装包，测试可用。使用rpm -ivh [rpm完整包名] 进行安装