rafka-rs 0.1.0

Rafka - A high-performance distributed message broker written in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

version: '3.8'

services:
  rafka-broker-1:
    build: .
    command: ["./start_broker", "--port", "50051", "--partition", "0", "--total-partitions", "3"]
    ports:
      - "50051:50051"
    environment:
      - RUST_LOG=info
    healthcheck:
      test: ["CMD", "nc", "-z", "localhost", "50051"]
      interval: 30s
      timeout: 10s
      retries: 3

  rafka-broker-2:
    build: .
    command: ["./start_broker", "--port", "50052", "--partition", "1", "--total-partitions", "3"]
    ports:
      - "50052:50052"
    environment:
      - RUST_LOG=info
    healthcheck:
      test: ["CMD", "nc", "-z", "localhost", "50052"]
      interval: 30s
      timeout: 10s
      retries: 3

  rafka-broker-3:
    build: .
    command: ["./start_broker", "--port", "50053", "--partition", "2", "--total-partitions", "3"]
    ports:
      - "50053:50053"
    environment:
      - RUST_LOG=info
    healthcheck:
      test: ["CMD", "nc", "-z", "localhost", "50053"]
      interval: 30s
      timeout: 10s
      retries: 3

  rafka-producer:
    build: .
    command: ["./start_producer", "--brokers", "rafka-broker-1:50051", "--message", "Hello from Docker Compose!", "--key", "docker-key"]
    depends_on:
      - rafka-broker-1
    environment:
      - RUST_LOG=info

  rafka-consumer:
    build: .
    command: ["./start_consumer", "--port", "50051"]
    depends_on:
      - rafka-broker-1
    environment:
      - RUST_LOG=info

networks:
  default:
    name: rafka-network