比较MQ产品之RabbitMQ与Kafka.zip

通过xmind思维导图的方式对kafka框架总结， 包含producer和consumer程序

kafkaUI.zip jar包和 ReadMe

kafkaUI-1.0.jar.tar.gz

2021年1.13号打包，最新版本：kafka-connect-oracle-1.0.68.jar，用于根据oracle binglog日志同步数据到kafka

本文来自于csdn，Kafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统.早期两个应用程序间进行消息传递需要保证两个应用程序同时在线，并且耦合度很高。为了解决应用程序不在线的情况下业务正常运转，就产生了消息系统，消费发送者（生产者）将消息发送至消息系统，消息接受者（消费者）从消息系统中获取消息。提到消息系统，不得不说一下JMS即Java消息服务（JavaMessageService）应用程序接口。是一个Java平台中关于面向消息中间件的API。用于在两个应用程序之间或分布式系统

storm流式计算的介绍，包括kafka、redis的介绍，包含日志系统、电商交易系统的文档。

电信行业案例：统计小区基站掉话率，整合kafka、storm、hbase，界面图表展示统计结果，比较典型的大数据应用案例

该文档是storm与kafka整合的工具包，可以直接进行kafka与storm对接，直接调用接口即可

使用log4j生成日志信息，使用flume对日志进行监控并采集，将采集到的数据放到kafka中使用storm对数据进行清洗和标准化，FilterBolt对error，warning等单词进行过滤，NotifyBolt触发规则之后，会往用户的邮箱发送邮件并发送短信通知用户。