diff --git a/docker-compose.yml b/docker-compose.yml index 059b715..dd4ceb4 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -1,4 +1,4 @@ -version: '3' + services: kafka: @@ -11,7 +11,7 @@ services: - KAFKA_CFG_NODE_ID=0 - KAFKA_CFG_PROCESS_ROLES=controller,broker - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093,EXTERNAL://:9094 - - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,EXTERNAL://localhost:9094 + - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,EXTERNAL://kafka:9094 - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT,PLAINTEXT:PLAINTEXT - KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=0@kafka:9093 - KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER @@ -27,13 +27,13 @@ services: - kafka environment: KAFKA_CLUSTERS_0_NAME: local - KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: PLAINTEXT://kafka:9092 + KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:9092 DYNAMIC_CONFIG_ENABLED: 'true' networks: - airflow-kafka docker-proxy: - image: bobrik/socat + image: alpine/socat command: "TCP4-LISTEN:2375,fork,reuseaddr UNIX-CONNECT:/var/run/docker.sock" ports: - "2376:2375" diff --git a/kafka/data/.lock b/kafka/data/.lock new file mode 100644 index 0000000..e69de29 diff --git a/kafka/data/__cluster_metadata-0/00000000000000000000.index b/kafka/data/__cluster_metadata-0/00000000000000000000.index new file mode 100644 index 0000000..48a7725 Binary files /dev/null and b/kafka/data/__cluster_metadata-0/00000000000000000000.index differ diff --git a/kafka/data/__cluster_metadata-0/00000000000000000000.timeindex b/kafka/data/__cluster_metadata-0/00000000000000000000.timeindex new file mode 100644 index 0000000..b743f6b Binary files /dev/null and b/kafka/data/__cluster_metadata-0/00000000000000000000.timeindex differ diff --git a/kafka/data/__cluster_metadata-0/leader-epoch-checkpoint b/kafka/data/__cluster_metadata-0/leader-epoch-checkpoint new file mode 100644 index 0000000..5b6be7e --- /dev/null +++ b/kafka/data/__cluster_metadata-0/leader-epoch-checkpoint @@ -0,0 +1,3 @@ +0 +1 +1 0 diff --git a/kafka/data/__cluster_metadata-0/partition.metadata b/kafka/data/__cluster_metadata-0/partition.metadata new file mode 100644 index 0000000..86273bd --- /dev/null +++ b/kafka/data/__cluster_metadata-0/partition.metadata @@ -0,0 +1,2 @@ +version: 0 +topic_id: AAAAAAAAAAAAAAAAAAAAAQ \ No newline at end of file diff --git a/kafka/data/__cluster_metadata-0/quorum-state b/kafka/data/__cluster_metadata-0/quorum-state new file mode 100644 index 0000000..e3a77b7 --- /dev/null +++ b/kafka/data/__cluster_metadata-0/quorum-state @@ -0,0 +1 @@ +{"clusterId":"","leaderId":0,"leaderEpoch":1,"votedId":-1,"appliedOffset":0,"currentVoters":[{"voterId":0}],"data_version":0} \ No newline at end of file diff --git a/kafka/data/bootstrap.checkpoint b/kafka/data/bootstrap.checkpoint new file mode 100644 index 0000000..99ec268 Binary files /dev/null and b/kafka/data/bootstrap.checkpoint differ diff --git a/kafka/data/cleaner-offset-checkpoint b/kafka/data/cleaner-offset-checkpoint new file mode 100644 index 0000000..e69de29 diff --git a/kafka/data/log-start-offset-checkpoint b/kafka/data/log-start-offset-checkpoint new file mode 100644 index 0000000..aa47d0d --- /dev/null +++ b/kafka/data/log-start-offset-checkpoint @@ -0,0 +1,2 @@ +0 +0 diff --git a/kafka/data/meta.properties b/kafka/data/meta.properties new file mode 100644 index 0000000..83c57c9 --- /dev/null +++ b/kafka/data/meta.properties @@ -0,0 +1,6 @@ +# +#Tue Mar 11 17:52:10 UTC 2025 +node.id=0 +directory.id=mCcBjoqoavyyUkeuUIP9pQ +version=1 +cluster.id=3vk0iUp7StSQ66evqTEYow diff --git a/kafka/data/recovery-point-offset-checkpoint b/kafka/data/recovery-point-offset-checkpoint new file mode 100644 index 0000000..aa47d0d --- /dev/null +++ b/kafka/data/recovery-point-offset-checkpoint @@ -0,0 +1,2 @@ +0 +0 diff --git a/kafka/data/replication-offset-checkpoint b/kafka/data/replication-offset-checkpoint new file mode 100644 index 0000000..e69de29