forked from wvanbergen/kazoo-go
/
Makefile
84 lines (53 loc) · 3.17 KB
/
Makefile
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
.PHONY: confluent/kafka/* confluent/zookeeper/* confluent/registry/* confluent/start confluent/stop fmt vet errcheck test test/create_kafka_topics dependencies dependencies/*
default: fmt vet errcheck test
# Confluent platform tasks
confluent/start: confluent/rest/start
confluent/stop: confluent/rest/stop confluent/registry/stop confluent/kafka/stop confluent/zookeeper/stop
# Download & extract tasks
confluent/confluent.tgz:
mkdir -p confluent && wget http://packages.confluent.io/archive/3.0/confluent-3.0.1-2.11.tar.gz -O confluent/confluent.tgz
confluent/EXTRACTED: confluent/confluent.tgz
tar xzf confluent/confluent.tgz -C confluent --strip-components 1 && mkdir confluent/logs && touch confluent/EXTRACTED
echo "delete.topic.enable=true" >> confluent/etc/kafka/server.properties
# Zookeeper tasks
confluent/zookeeper/start: confluent/EXTRACTED
nohup confluent/bin/zookeeper-server-start confluent/etc/kafka/zookeeper.properties 2> confluent/logs/zookeeper.err > confluent/logs/zookeeper.out < /dev/null &
while ! nc localhost 2181 </dev/null; do echo "Waiting for zookeeper..."; sleep 1; done
confluent/zookeeper/stop: confluent/EXTRACTED
confluent/bin/zookeeper-server-stop
# Kafka tasks
confluent/kafka/start: confluent/zookeeper/start confluent/EXTRACTED
nohup confluent/bin/kafka-server-start confluent/etc/kafka/server.properties 2> confluent/logs/kafka.err > confluent/logs/kafka.out < /dev/null &
while ! nc localhost 9092 </dev/null; do echo "Waiting for Kafka..."; sleep 1; done
confluent/kafka/stop: confluent/EXTRACTED
confluent/bin/kafka-server-stop
# schema-registry tasks
confluent/registry/start: confluent/kafka/start confluent/EXTRACTED
nohup confluent/bin/schema-registry-start confluent/etc/schema-registry/schema-registry.properties 2> confluent/logs/schema-registry.err > confluent/logs/schema-registry.out < /dev/null &
while ! nc localhost 8081 </dev/null; do echo "Waiting for schema registry..."; sleep 1; done
confluent/registry/stop: confluent/EXTRACTED
confluent/bin/kafka-server-stop
# REST proxy tasks
confluent/rest/start: confluent/registry/start confluent/EXTRACTED
nohup confluent/bin/kafka-rest-start confluent/etc/kafka-rest/kafka-rest.properties 2> confluent/logs/kafka-rest.err > confluent/logs/kafka-rest.out < /dev/null &
while ! nc localhost 8082 </dev/null; do echo "Waiting for REST proxy..."; sleep 1; done
confluent/rest/stop: confluent/EXTRACTED
confluent/bin/kafka-rest-stop
# CI tasks
test:
go test -v -race ./...
vet:
go vet ./...
errcheck:
errcheck ./...
fmt:
@if [ -n "$$(go fmt ./...)" ]; then echo 'Please run go fmt on your code.' && exit 1; fi
dependencies: dependencies/errcheck dependencies/get
dependencies/errcheck:
go get github.com/kisielk/errcheck
dependencies/get:
go get -t ./...
test/create_kafka_topics: confluent/kafka/start
confluent/bin/kafka-topics --create --partitions 1 --replication-factor 1 --topic test.1 --zookeeper localhost:2181
confluent/bin/kafka-topics --create --partitions 4 --replication-factor 1 --topic test.4 --zookeeper localhost:2181 --config retention.ms=604800000
confluent/bin/kafka-topics --create --partitions 64 --replication-factor 1 --topic test.64 --zookeeper localhost:2181