上述也表示了数据成功的写入了kafka。
因为是实时的从kafka那数据，我们也可以从控制台查看打印的语句。
控制台输出:
INFO com.pancm.storm.spout.KafkaInsertDataSpout - Spout发射的数据:[{"age":5,"name":"王五"}, {"age":10,"name":"李四"}, {"age":20,"name":"张三"}] WARN com.pancm.storm.bolt.InsertBolt - Bolt移除的数据:{"age":5,"name":"王五"} INFO com.alibaba.druid.pool.DruidDataSource - {dataSource-1} inited DEBUG com.pancm.dao.UserDao.insertBatch - ==> Preparing: insert into t_user (name,age) values (?,?) , (?,?) DEBUG com.pancm.dao.UserDao.insertBatch - ==> Parameters: 李四(String), 10(Integer), 张三(String), 20(Integer) DEBUG com.pancm.dao.UserDao.insertBatch - <== Updates: 2 INFO com.pancm.service.impl.UserServiceImpl - 批量新增2条数据成功!可以在控制台成功的看到处理的过程和结果。
然后我们也可以通过接口进行数据库所有的数据查询。
查询请求:
GET :8087/api/user返回结果:
[{"id":1,"name":"李四","age":10},{"id":2,"name":"张三","age":20}]上述代码中测试返回的结果显然是符合我们预期的。
结语关于SpringBoot整合kafka和storm暂时就告一段落了。本篇文章只是简单的介绍这些 相关的使用，在实际的应用可能会更复杂。如果有有更好的想法和建议，欢迎留言进行讨论！
SpringBoot整合kafka和storm的工程我放在github上了，如果感觉不错的话请给个star吧。
Gihub地址:https://github.com/xuwujing/springBoot-study
对了，也有kafka整合storm的工程，也在我的github上。
地址:https://github.com/xuwujing/kafka-study