kafka是一个分布式发布订阅消息系统，这里我们使用kafkajs来实现数据的发送和消息的订阅处理
默认已经安装好
docker，node，yarn和typescript
$ docker-compose up --no-recreate关于为什么要添加
--no-recreate，查看#516 和Broker IDs
$ yarn$ yarn run all-
Notifications
You must be signed in to change notification settings - Fork 0
yxlazy/kafka
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
kafka是一个分布式发布订阅消息系统，这里使用canal作为Producer，将mysql中的数据放入到kafka消息队列中，再通过kafkajs来消费数据
Topics
Resources
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published