Streaming Demo

• https://kafka.apache.org/quickstart

System Info

docker pull apache/kafka:3.9.0
docker run -p 9092:9092 apache/kafka:3.9.0

go run producers/sysinfo/sysinfo.go

go run consumers/sysinfo/sysinfo.go

Notify

docker pull apache/kafka:3.9.0
docker run -p 9092:9092 apache/kafka:3.9.0

go run producers/notify/notify.go

curl --location 'http://localhost:3000/notify' --form 'message="Hello World!"'

GROUP_ID=notify-consumer-group-1 go run consumers/notify/notify.go
GROUP_ID=notify-consumer-group-2 go run consumers/notify/notify.go