From f29e6eb8a20edebce65a3ecca792ce28ba602492 Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Tue, 1 Aug 2017 13:03:55 +0200 Subject: 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. --- 11confluent-config.yml | 3 ++- test/rest-curl.yml | 5 +---- 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-.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 "" -- cgit v1.2.3