async-cqrs

Sample application

sequenceDiagram
  client ->> api: POST /command
  activate api
  api ->> broker: publish events
  server -->> broker: subscribe events
  activate server
  server ->> broker: publish replies
  deactivate server
  api -->> broker: subscribe replies
  api ->> client: response
  deactivate api

  client -) api: GET /query (SSE)
  activate api
  api --) broker: subscribe [topic]
  server -) broker: publish [topic]

Loading

Setup

docker compose up -d

docker compose run --rm rpk topic create mytopic --brokers redpanda:9092

Usage

# http
# https://github.com/aklivity/zilla-examples/tree/main/http.kafka.sync
cd zilla-http

curl -X POST http://localhost:9090/command -H "Idempotency-Key: 135e4567-e89b-12d3-a456-42661417426"

# gRPC
# https://github.com/aklivity/zilla-examples/tree/main/grpc.kafka.echo
cd zilla-grpc

grpcurl -plaintext -proto proto/echo.proto  -d '{"message":"Hello World"}' -H 'idempotency-key: 135e4567-e89b-12d3-a456-42661417427' localhost:9090 example.EchoService.EchoUnary

ghz --config bench.json --proto proto/echo.proto --call example.EchoService/EchoBidiStream localhost:9090

Usage

curl -X POST http://localhost:9090/command -H "Idempotency-Key: 73eb15c7-d554-4bf5-adab-1834f6b3c015"

curl -X POST http://localhost:9090/command -H "Idempotency-Key: 135e4567-e89b-12d3-a456-426614174264"
curl -X POST http://localhost:9090/command -H "Idempotency-Key: 135e4567-e89b-12d3-a456-426614174264"