kafka-manager-2.0.0.2
原本下载个老版的，有bug无法创建topic；
无奈耗时2天，自己动手编译kafka-manager-2.0.0.2，编译成功，实测可用，大家放心使用！！
2022-07-29 19:06:03
92.21MB
1
1、flink监听localhost的kafka，作为source，接收数据。
2、数据流转到elasticsearch
3、flink web ui提交jar文件，创建任务流程。
4、流程测试。
2022-07-23 09:06:16
148.13MB
1
可以用来当做一个kafka项目的框架。
本项目里面简单写了单挑信息、批量信息的web接口测试消息发送，并且注入了两个bean，实现KafkaListener两种不同模式{containerFactory="batchFactory"}，{containerFactory = "batchFactoryOff"}。
2022-06-27 19:09:36
21KB
这篇博文《Flink消费Kafka主题消息的演示》需要的Kafka依赖包
2022-06-25 09:09:29
2.61MB
1
这篇博文《Flink消费Kafka主题消息的演示》需要的Kafka依赖包
2022-06-25 09:09:28
104KB
1
这篇博文《Flink消费Kafka主题消息的演示》需要的Kafka依赖包
2022-06-25 09:09:28
54KB
1
这篇博文《Flink消费Kafka主题消息的演示》需要的Kafka依赖包
2022-06-25 09:09:27
26KB
1
这篇博文《Flink消费Kafka主题消息的演示》需要的Kafka依赖包
2022-06-25 09:09:27
37KB
1
Pulsar 作为下一代云原生分布式消息流平台，支持多租户、持久化存储、多机房跨区域数据复制，具有强一致性、高吞吐以及低延时的高可扩展流数据存储特性，内置诸多其他系统商业版本才有的特性，是云原生时代解决实时消息流数据传输、存储和计算的最佳解决方案。
2022-06-17 09:11:12
337.26MB
1