diff --git a/operations-playground/docker-compose.yaml b/operations-playground/docker-compose.yaml index a031fbd..b99a948 100644 --- a/operations-playground/docker-compose.yaml +++ b/operations-playground/docker-compose.yaml @@ -55,7 +55,7 @@ services: environment: - JOB_MANAGER_RPC_ADDRESS=jobmanager kafka: - image: 'bitnami/kafka:3.9.0' + image: 'bitnamilegacy/kafka:3.9.0' environment: - KAFKA_CFG_NODE_ID=0 - KAFKA_CFG_NUM_PARTITIONS=2 diff --git a/pyflink-walkthrough/docker-compose.yml b/pyflink-walkthrough/docker-compose.yml index 7d7790e..c83cb42 100644 --- a/pyflink-walkthrough/docker-compose.yml +++ b/pyflink-walkthrough/docker-compose.yml @@ -45,7 +45,7 @@ services: environment: - JOB_MANAGER_RPC_ADDRESS=jobmanager kafka: - image: 'bitnami/kafka:3.9.0' + image: 'bitnamilegacy/kafka:3.9.0' environment: - KAFKA_CFG_NODE_ID=0 - KAFKA_CFG_PROCESS_ROLES=controller,broker diff --git a/table-walkthrough/docker-compose.yml b/table-walkthrough/docker-compose.yml index 655091a..4764ca7 100644 --- a/table-walkthrough/docker-compose.yml +++ b/table-walkthrough/docker-compose.yml @@ -45,7 +45,7 @@ services: environment: - JOB_MANAGER_RPC_ADDRESS=jobmanager kafka: - image: 'bitnami/kafka:3.9.0' + image: 'bitnamilegacy/kafka:3.9.0' environment: - KAFKA_CFG_NODE_ID=0 - KAFKA_CFG_PROCESS_ROLES=controller,broker