use cp-enterprise-kafka image in all-in-one example. Also enabled metrics
@@ -11,16 +11,23 @@ services:
ZOOKEEPER_TICK_TIME: 2000
broker:
- image: confluentinc/cp-kafka
+ image: confluentinc/cp-enterprise-kafka
hostname: broker
depends_on:
- zookeeper
ports:
- - '9092'
+ - "9092"
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT://broker:9092'
+ KAFKA_METRIC_REPORTERS: io.confluent.metrics.reporter.ConfluentMetricsReporter
+ CONFLUENT_METRICS_REPORTER_BOOTSTRAP_SERVERS: broker:9092
+ CONFLUENT_METRICS_REPORTER_ZOOKEEPER_CONNECT: zookeeper:2181
+ CONFLUENT_METRICS_REPORTER_TOPIC_REPLICAS: 1
+ CONFLUENT_METRICS_ENABLE: 'true'
+ CONFLUENT_SUPPORT_CUSTOMER_ID: 'anonymous'
+ CONFLUENT_METRICS_REPORTER_PUBLISH_MS: 1000
schema_registry:
image: confluentinc/cp-schema-registry
@@ -29,7 +36,7 @@ services:
- zookeeper
- broker
ports:
- - '8081'
+ - "8081"
environment:
SCHEMA_REGISTRY_HOST_NAME: schema_registry
SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: 'zookeeper:2181'
@@ -42,7 +49,7 @@ services:
- broker
- schema_registry
ports:
- - "8083:8083"
+ - "8083"
environment:
CONNECT_BOOTSTRAP_SERVERS: 'broker:9092'
CONNECT_REST_ADVERTISED_HOST_NAME: connect
