没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
本项目验证了storm1.1.1从kafka2.12-1.0.0消费数据,将统计结果保存到redis中。项目自带kafka生产者testcase。具体用法请看README.md的[Order of execution]部分。集群部署过程也在此文件的reference网页。集群的storm,kafka版本与项目版本要一致,否则会kafka消息出现乱码。
资源推荐
资源详情
资源评论
收起资源包目录
kafkaStormRedis.rar (64个子文件)
kafkaStormRedis
.gitignore 9B
.project 567B
README.md 1KB
pom.xml 3KB
target
.settings
org.eclipse.core.resources.prefs 118B
org.eclipse.jdt.core.prefs 243B
org.eclipse.m2e.core.prefs 90B
src
test
java
com
storm
KafkaStorm
main
java
META-INF
MANIFEST.MF 64B
com
storm
utils
ConfigUtils.java 1KB
MapUtils.java 784B
producer
WordsProducer.java 4KB
bolt
CountBolt.java 2KB
SplitBolt.java 1KB
RedisBolt.java 2KB
topo
KafkaStormTopo.java 2KB
.classpath 1024B
.git
HEAD 23B
packed-refs 107B
index 2KB
FETCH_HEAD 102B
COMMIT_EDITMSG 616B
objects
d5
9e09c909d399acee329944c7b4ac2437a0b0fa 131B
4d
95ecbc04fc771050d5fb9d69fa280d230e7db0 504B
48
c57e33b23be5c24ff39a6df9b46698d7581e87 444B
a9
f72801144da0ca531b53c8485c59d57e3cd188 798B
aa
374a162f6fa3f618ea0731b1449b05ea82258d 120B
08
7ce0abbc78d31a5d0f2141077c5e2e94193b12 46B
02
e77922e533ec16e86a43c237ee9c5fa0f82d22 517B
b8
3d22266ac8aa2f8df2edef68082c789727841d 24B
53
68108a9624139f1d521c6fbf3c4b4ab3ead61e 504B
d6
2f30f666115f396e44fd768dbcbe0f3c147c0d 253B
42
9cd628cec3cfb9c6cbc02a893ddf327ceb3aec 601B
e7
11a2b4669929511948127cbae02f55a622364b 114B
pack
b1
da33ae0ee08b5915b2be8f70d04353ed274791 526B
db
0a409c19c1b1bb7e8ceec43ba97cd28657fbfb 77B
86
4a764866944ae324c9b894a37414d3bbc0e174 635B
11
08456c715ab399f49eb7df57318c53e1f0eaac 46B
57
b55e55895fe1b0c0b21a7c323c0e1a29adeb78 480B
68
c46585edd3b30fc2efd6b7149e4e7da64c4368 97B
89
0147a6a382c90ecd3af438857f8555c1f5d533 77B
1a
4f7a4a3e38d452759ac70c5265849153615de0 524B
33
6a4fc19ee1879bc84ab0070d24728a986c90b4 47B
61
b6d230bdfdfa6c38d24ee9601283a0f3657418 63B
14
b697b7bbb0d85e8d8ee19141a2a92d9ce211be 90B
98
ab964facbd91cb4730faa8602d2ac9c56c5976 836B
58
5e9acba9a61f5dd2a1fc7fe91cf81947df2b17 2KB
de2adb94da7b28f215d631bab3e3189d1c15d0 54B
4e
72468195924edf3cc7ef5c43ec32a4989c12dc 136B
552539a119a9d6acd9148769bd4c45746849d6 56B
94
789af267bd69aa5c15577daa6a2d87a6463782 64B
a4
95a970ce6bb619a944e8aad9a64c51fd53d2c1 246B
74
cf9e524e83e53d0cfbae04b9f6a84a19f4420e 139B
40
f54e611872cdf46728a9c55fd0f65f5db2e0a8 89B
info
01
edbc47b9a6238031106a2b1388b6e805cce540 327B
9b
9c7607e748d023565424fa7b9c3d0dfe3f27b8 817B
config 350B
sourcetreeconfig 939B
logs
HEAD 336B
refs
heads
master 336B
remotes
origin
HEAD 182B
master 139B
refs
tags
heads
master 41B
remotes
origin
HEAD 32B
master 41B
共 64 条
- 1
资源评论
- #完美解决问题
- #运行顺畅
- #内容详尽
- #全网独家
- #注释完整
- Get小乌龟2018-06-28垃圾资源骗分的
- WSQ4585423239762018-04-19使用CountBolt报错,RedisBolt不报错,很好的一个例子,整了好几天,终于有一个可以用的了,谢谢分享
- 身戴金甲圣衣2018-06-27我也下载了 ,在nimbuer启动之后,super 一直报错阿(kill: 向 5575 发送信号失败: 没有那个进程) ,怎么会回事
cjrjc
- 粉丝: 75
- 资源: 13
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- java版考试管理系统(前后端分离、springboot、vue、mysql)
- STM32F103C8T6驱动步进电机
- Python+OpenCV魔方识别系统(源码和部署教程).zip
- Video-2024-10-05下午-线程同步1.wmv
- 15个前端数据大屏展示图+源代码下载
- vue大屏显示数据分析源码
- 基于非下采样小波包分析的轴承故障诊断 代码运行环境为MATLAB r2021b,非下采样小波包变执行信号的等带宽精细滤波,而不是离散小波变中的较粗糙的倍频程滤,而且很好的缓解了小波包变中的时间分辨
- Nessus2025.01.06
- 松下 WV-S2236L WV-S2136L WV-S2136 网络摄像机 安装指南.pdf
- 用户手册计数器 计时器CX系列.pdf
- llc半桥变器多种控制方式仿真模型,包括 变频控制(PFM) PWM控制(占空比控制) 滞环控制(bang-bang控制) 自抗扰控制(采用的是一阶ADRC模型) 等控制方式的半桥llc谐振变器仿真模
- 微博热搜数据可视化分析系统技术框架python + flask web + mysql
- CLASSIC(WV)旋转喷嘴用户手册.pdf
- Schneider Electric Industries MODBUS TCP Master 驱动程序 GP-Pro EX 控制器 PLC 连接手册.pdf
- Video-2024-10-05下午-线程同步2.wmv
- 饥饿游戏搜索HGS优化算法对BP的权值和阈值做优化,建立多分类和二分类预测模型 程序内注释详细,可学习性强 直接替数据就可以用 程序语言为matlab 同时接优化算法和机器学习算法结合的定制模
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功