eventsourcing-example/init-topics.sh at master · ninjatux/eventsourcing-example · GitHub

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
#!/usr/bin/env sh
kontena service exec --shell kafka-cluster/kafka /usr/bin/kafka-topics \
    --create \
    --zookeeper \$KAFKA_ZOOKEEPER_CONNECT:2181 \
    --replication-factor 2 \
    --partitions 1 \
    --config cleanup.policy=compact \
    --config retention.bytes=-1 \
    --config retention.ms=-1  \
    --topic eventbus.products

kontena service exec --shell kafka-cluster/kafka /usr/bin/kafka-topics \
    --create \
    --zookeeper \$KAFKA_ZOOKEEPER_CONNECT:2181 \
    --replication-factor 2 \
    --partitions 1 \
    --config cleanup.policy=compact \
    --config retention.bytes=-1 \
    --config retention.ms=-1  \
    --topic eventbus.purchases

kontena service exec --shell kafka-cluster/kafka /usr/bin/kafka-topics \
    --create \
    --zookeeper \$KAFKA_ZOOKEEPER_CONNECT:2181 \
    --replication-factor 2 \
    --partitions 1 \
    --config cleanup.policy=compact \
    --config retention.bytes=-1 \
    --config retention.ms=-1  \
    --topic eventbus.customers