oslo.messaging/setup-test-env-kafka.sh

17 lines
440 B
Bash
Executable File

#!/bin/bash
set -e
. tools/functions.sh
DATADIR=$(mktemp -d /tmp/OSLOMSG-KAFKA.XXXXX)
trap "clean_exit $DATADIR" EXIT
SCALA_VERSION="2.11"
KAFKA_VERSION="0.10.1.0"
tarball=kafka_${SCALA_VERSION}-${KAFKA_VERSION}.tgz
wget http://apache.crihan.fr/dist/kafka/${KAFKA_VERSION}/$tarball -O $DATADIR/$tarball
tar -xzf $DATADIR/$tarball -C $DATADIR
export PATH=$DATADIR/kafka_${SCALA_VERSION}-${KAFKA_VERSION}/bin:$PATH
pifpaf run kafka -- $*