Push service by node with kafka
npm init
npm install koa koa-static koa-bodyparser koa-router web-push kafka-node
kafka-node
package.json
"kafka-node": {
"version": "^3.0.1",
"no-optional": "true"
},
./node_modules/.bin/web-push generate-vapid-keys
Public Key:
BIxeru5kL-OXk3YtHVylXI-gemgilsoesL80YEKb_P9v5Y77Buh8afeZgP8-PbQErv8X5TQ9qwl97mJK8_wtlSs
Private Key:
qkxmH3zHvdhTbAyk__ty05PDePJtC6Nzko3zpzHKE5k
For test, use my kafka-manager/docker-compose.yml
Edit KAFKA_ADVERTISED_HOST_NAME: <HOSTIP>
by your host ip.
and
docker-compose up -d
make topic
Go to localhost:9000.
Kafka Manager - Menu - Cluster - Add Cluster
- Cluster Name: anything
- Cluster Zookeeper Hosts:
zoo:2181
- Check:
- Enable JMX Polling (Set JMX_PORT env variable before starting kafka server)
- Poll consumer information (Not recommended for large # of consumers)
Save
and go to your Cluster.
Kafka Manager - Menu - Topic - Create
- Topic: topic-test (the node server code's topic name is 'topic-test')
- Partition: 1
- Replication Factor: 1
Create
node server.js
and go to 'localhost:3000'
use Chrome or Firefox.