rustfs-kafka 1.2.0

Rust client for Apache Kafka
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

services:
  zookeeper:
    image: zookeeper:3.7.2
    profiles:
      - zk
    ports:
      - "2181:2181"
    healthcheck:
      test: ["CMD-SHELL", "echo ruok | nc localhost 2181 || exit 1"]
      interval: 5s
      timeout: 3s
      retries: 10
      start_period: 5s

  kafka:
    build:
      context: kafka-rust-image
      args:
        kafka_version: ${KAFKA_VER}
        scala_version: ${SCALA_VER}
    ports:
      - "9092:9092"
    environment:
      KAFKA_CREATE_TOPICS: kafka-rust-test:2:1,kafka-rust-test2:2:1
      KAFKA_CLIENT_SECURE: ${KAFKA_CLIENT_SECURE}
      KAFKA_CLIENT_SASL_MECHANISM: ${KAFKA_CLIENT_SASL_MECHANISM}
      KAFKA_CLIENT_SASL_USERNAME: ${KAFKA_CLIENT_SASL_USERNAME}
      KAFKA_CLIENT_SASL_PASSWORD: ${KAFKA_CLIENT_SASL_PASSWORD}
      KAFKA_VERSION: ${KAFKA_VER}
    restart: unless-stopped