Skip to content

Commit a611f25

Browse files
committed
Add Kafka KRaft mode support with Conduktor and JMX integration
1 parent db91a8b commit a611f25

File tree

1 file changed

+57
-0
lines changed

1 file changed

+57
-0
lines changed

conduktor-kafka-single.yml

Lines changed: 57 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,57 @@
1+
services:
2+
postgresql:
3+
image: postgres:14
4+
hostname: postgresql
5+
volumes:
6+
- pg_data:/var/lib/postgresql/data
7+
environment:
8+
POSTGRES_DB: "conduktor-console"
9+
POSTGRES_USER: "conduktor"
10+
POSTGRES_PASSWORD: "some_password"
11+
POSTGRES_HOST_AUTH_METHOD: "scram-sha-256"
12+
conduktor-console:
13+
image: conduktor/conduktor-console:1.34.0
14+
ports:
15+
- "8080:8080"
16+
volumes:
17+
- conduktor_data:/var/conduktor
18+
environment:
19+
CDK_DATABASE_URL: "postgresql://conduktor:some_password@postgresql:5432/conduktor-console"
20+
CDK_CLUSTERS_0_ID: "default"
21+
CDK_CLUSTERS_0_NAME: "My Local Kafka Cluster"
22+
CDK_CLUSTERS_0_COLOR: "#0013E7"
23+
CDK_CLUSTERS_0_BOOTSTRAPSERVERS: "PLAINTEXT://kafka1:19092"
24+
# CONSOLE_JAVA_OPTS: "-XX:UseSVE=0"
25+
CDK_CLUSTERS_0_JMXPORT: "9999"
26+
CDK_CLUSTERS_0_JMXHOST: "kafka1"
27+
kafka1:
28+
image: confluentinc/cp-kafka:7.8.0
29+
hostname: kafka1
30+
container_name: kafka1
31+
ports:
32+
- "9092:9092"
33+
- "29092:29092"
34+
- "9999:9999" # JMX Port
35+
- "9099:9099" # Internal inter-broker communication
36+
environment:
37+
environment:
38+
CLUSTER_ID: MkU3OEVBNTcwNTJENDM2Qk
39+
KAFKA_NODE_ID: 1
40+
KAFKA_PROCESS_ROLES: broker,controller
41+
KAFKA_CONTROLLER_QUORUM_VOTERS: "1@kafka1:9099"
42+
KAFKA_LISTENERS: INTERNAL://0.0.0.0:19092,EXTERNAL://0.0.0.0:9092,DOCKER://0.0.0.0:29092,CONTROLLER://0.0.0.0:9099
43+
KAFKA_ADVERTISED_LISTENERS: INTERNAL://kafka1:19092,EXTERNAL://${DOCKER_HOST_IP:-127.0.0.1}:9092,DOCKER://host.docker.internal:29092
44+
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT,DOCKER:PLAINTEXT,CONTROLLER:PLAINTEXT
45+
KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
46+
KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
47+
KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO"
48+
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
49+
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
50+
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
51+
KAFKA_JMX_PORT: 9999
52+
KAFKA_JMX_HOSTNAME: ${DOCKER_HOST_IP:-127.0.0.1}
53+
KAFKA_AUTHORIZER_CLASS_NAME: org.apache.kafka.metadata.authorizer.StandardAuthorizer
54+
KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND: "true"
55+
volumes:
56+
pg_data: {}
57+
conduktor_data: {}

0 commit comments

Comments
 (0)