2019-05-21 20:56:55 +00:00
|
|
|
#! /bin/bash
|
2017-03-01 14:55:27 +00:00
|
|
|
|
2017-10-10 10:02:39 +00:00
|
|
|
# Downloads, installs and runs a kafka instance
|
|
|
|
|
|
2017-03-01 14:55:27 +00:00
|
|
|
set -eu
|
|
|
|
|
|
2017-12-19 14:09:15 +00:00
|
|
|
cd `dirname $0`/..
|
|
|
|
|
|
|
|
|
|
mkdir -p .downloads
|
|
|
|
|
|
2019-05-21 20:56:55 +00:00
|
|
|
KAFKA_URL=http://archive.apache.org/dist/kafka/2.1.0/kafka_2.11-2.1.0.tgz
|
2017-03-01 14:55:27 +00:00
|
|
|
|
|
|
|
|
# Only download the kafka if it isn't already downloaded.
|
2019-05-21 20:56:55 +00:00
|
|
|
test -f .downloads/kafka.tgz || wget $KAFKA_URL -O .downloads/kafka.tgz
|
2017-03-01 14:55:27 +00:00
|
|
|
# Unpack the kafka over the top of any existing installation
|
2017-12-19 14:09:15 +00:00
|
|
|
mkdir -p kafka && tar xzf .downloads/kafka.tgz -C kafka --strip-components 1
|
2017-03-01 14:55:27 +00:00
|
|
|
# Start the zookeeper running in the background.
|
|
|
|
|
# By default the zookeeper listens on localhost:2181
|
|
|
|
|
kafka/bin/zookeeper-server-start.sh -daemon kafka/config/zookeeper.properties
|
|
|
|
|
# Enable topic deletion so that the integration tests can create a fresh topic
|
|
|
|
|
# for each test run.
|
2017-11-21 12:13:01 +00:00
|
|
|
echo -e "\n\ndelete.topic.enable=true" >> kafka/config/server.properties
|
2017-03-01 14:55:27 +00:00
|
|
|
# Start the kafka server running in the background.
|
|
|
|
|
# By default the kafka listens on localhost:9092
|
|
|
|
|
kafka/bin/kafka-server-start.sh -daemon kafka/config/server.properties
|
