aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2017-08-01 13:03:55 +0200
committerStaffan Olsson <staffan@repos.se>2017-08-01 14:04:27 +0200
commitf29e6eb8a20edebce65a3ecca792ce28ba602492 (patch)
treecc266bc7f97fdefe758891aa47a5c8e312e09005
parenteb1a1020055ecca572d0dac9a9d5bfb853b3d722 (diff)
downloadkubernetes-kafka-f29e6eb8a20edebce65a3ecca792ce28ba602492.tar.gz
kubernetes-kafka-f29e6eb8a20edebce65a3ecca792ce28ba602492.tar.bz2
kubernetes-kafka-f29e6eb8a20edebce65a3ecca792ce28ba602492.zip
Logs, unlike docs, revealed that kafka-rest needs ...
both zookeeper and bootstrap addresses. Was getting connection errors to localhost:9092 broker id -1, resulting in REST requests never returning.
-rw-r--r--11confluent-config.yml3
-rw-r--r--test/rest-curl.yml5
2 files changed, 3 insertions, 5 deletions
diff --git a/11confluent-config.yml b/11confluent-config.yml
index df91677..12fa7db 100644
--- a/11confluent-config.yml
+++ b/11confluent-config.yml
@@ -43,8 +43,9 @@ data:
#id=kafka-rest-test-server
listeners=http://0.0.0.0:80
- schema.registry.url=http://schemas.kafka.svc.cluster.local:80
+ bootstrap.servers=kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
zookeeper.connect=zookeeper:2181
+ schema.registry.url=http://schemas.kafka.svc.cluster.local:80
#
# Configure interceptor classes for sending consumer and producer metrics to Confluent Control Center
# Make sure that monitoring-interceptors-<version>.jar is on the Java class path
diff --git a/test/rest-curl.yml b/test/rest-curl.yml
index 05fc178..7ee719a 100644
--- a/test/rest-curl.yml
+++ b/test/rest-curl.yml
@@ -22,10 +22,7 @@ data:
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 -u -Iseconds)\"}]}" \
- $REST/topics/$TOPIC -v --max-time 30 \
- || echo " (timeout might be ok because we only want to send one message)"
- # TODO why does the above block?
-
+ $REST/topics/$TOPIC
curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC/partitions
echo ""