Sha256: b917a6899db1d6a899ed86725938c3e46c2dff8b2da3b55d869640ee5c3f0568
Contents?: true
Size: 442 Bytes
Versions: 8
Compression:
Stored size: 442 Bytes
Contents
#!/bin/bash
set -eu
UTILS_DIR=$(dirname $0)
source ${UTILS_DIR}/env.sh
ZK_IP=$(docker inspect --format '{{ .NetworkSettings.IPAddress }}' zookeeper)
TOPIC=${TOPIC:='test'}
PARTITIONS=${PARTITIONS:=2}
echo "creating topic ${TOPIC}, partitions ${PARTITIONS}"
docker run --rm $KAFKA_IMAGE:$KAFKA_IMAGE_VERSION kafka-topics.sh \
--create \
--topic $TOPIC \
--replication-factor 1 \
--partitions $PARTITIONS \
--zookeeper $ZK_IP:2181
Version data entries
8 entries across 8 versions & 1 rubygems