-
Start Docker Daemon
-
Run Zookeeper:
docker run --name zookeeper -p 2181:2181 zookeeper
-
Run Kafka:
docker run --name kafka -p 9092:9092 \ -e KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \ -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 \ -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 \ --link zookeeper:zookeeper \ confluentinc/cp-kafka
-
Copy Repository and Run:
-
Run the producer:
go run cmd/producer/producer.go
-
Run the consumer:
go run cmd/consumer/consumer.go
-
-
Produce Messages:
Use
curlto send messages:curl -X POST http://localhost:8080/send \ -d "fromID=<id>&toID=<id>&message=<message>" -
Consume Messages:
Use
curlto retrieve notifications:curl http://localhost:8081/notifications/<id>
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent