Nest.js Kafka演示
设置
Kafka，其依赖项和Kafdrop（Kafka UI）
$ docker-compose up # to start
$ docker-compose down # to stop
$ docker-compose down -v --rmi all # full cleanup
Nest.js生产者服务
$ cd kafka-microservice-client-producer
$ yarn install # install dependencies
$ yarn start:dev
Nest.js消费者服务
$ cd kafka-microservice-server-consumer
$ yarn install # install dependencies
$ yarn start:dev
用法
查看日志，检查一切是否正常。
要发送
2022-02-08 10:41:46
218KB
1
以flink处理kafka消息流场景为例，将接受到的kafka消息sink到mysql、elastic、hdfs、kafka，通过真实的案例，助你入门flink计算框架。课程案例代码也可移植到其它业务系统，实现快速开发。
2022-02-07 14:56:39
287.37MB
1
flink sql学习组件，里面包含flink、flink sql clienk、kafka 、ES、mysql等，使用docker命令加载即可，适用于macos，linux系统学习flink
2022-01-27 09:11:48
2KB
1