File tree Expand file tree Collapse file tree 1 file changed +16
-7
lines changed Expand file tree Collapse file tree 1 file changed +16
-7
lines changed Original file line number Diff line number Diff line change 9
9
setup.sh : |-
10
10
touch /tmp/testlog
11
11
12
- # Don't complete startup until rest proxy is up and running
13
- curl --retry 10 --retry-delay 30 --retry-connrefused -I $REST;
12
+ # Keep starting up until rest proxy is up and running
13
+ curl --retry 10 --retry-delay 30 --retry-connrefused -I -s $REST
14
14
15
15
16
- curl -H 'Accept: application/vnd.kafka.v2+json' $REST/topics;
16
+ curl -H 'Accept: application/vnd.kafka.v2+json' $REST/topics
17
+ echo ""
17
18
18
- curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/test1;
19
- curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" --data "{\"records\":[{\"value\":\"Test from $HOSTNAME at $(date)\"}]}" $REST/topics/$TOPIC -v;
20
- curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/test2;
19
+ curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC
20
+ echo ""
21
21
22
- curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" --data '{"records":[{"value":{"foo":"bar"}}]}' $REST/topics/$TOPIC -v;
22
+ curl -X POST \
23
+ -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" \
24
+ --data "{\"records\":[{\"value\":\"Test from $HOSTNAME at $(date -u -Iseconds)\"}]}" \
25
+ $REST/topics/$TOPIC -v --max-time 30 \
26
+ || echo " (timeout might be ok because we only want to send one message)"
27
+ # TODO why does the above block?
28
+
29
+
30
+ curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC/partitions
31
+ echo ""
23
32
24
33
curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"name": "my_consumer_instance", "format": "json", "auto.offset.reset": "earliest"}' $REST/consumers/my_json_consumer -v;
25
34
You can’t perform that action at this time.
0 commit comments