@@ -12,7 +12,7 @@ services:
1212 # Apache Kafka
1313 # ------------
1414 kafka :
15- image : ${KAFKA_IMAGE}
15+ image : docker.io/apache/kafka:4.0.0
1616 ports :
1717 - " ${PORT_KAFKA_BROKER_INTERNAL}:${PORT_KAFKA_BROKER_INTERNAL}"
1818 - " ${PORT_KAFKA_BROKER_EXTERNAL}:${PORT_KAFKA_BROKER_EXTERNAL}"
@@ -43,7 +43,7 @@ services:
4343 # CrateDB
4444 # -------
4545 cratedb :
46- image : crate:${CRATEDB_VERSION}
46+ image : docker.io/ crate:5.10.11
4747 ports :
4848 - " ${CRATEDB_HTTP_PORT}:${CRATEDB_HTTP_PORT}"
4949 - " ${CRATEDB_POSTGRESQL_PORT}:${CRATEDB_POSTGRESQL_PORT}"
@@ -73,7 +73,7 @@ services:
7373 # status, even when using `docker compose up --detach`.
7474 # https://marcopeg.com/2019/docker-compose-healthcheck/
7575 start-dependencies :
76- image : dadarek/wait-for-dependencies
76+ image : docker.io/ dadarek/wait-for-dependencies
7777 depends_on :
7878 kafka :
7979 condition : service_healthy
@@ -87,31 +87,31 @@ services:
8787
8888 # Create Kafka topic.
8989 create-topic :
90- image : ${KAFKA_IMAGE}
90+ image : docker.io/apache/kafka:4.0.0
9191 networks : [ingestr-demo]
9292 command : /opt/kafka/bin/kafka-topics.sh --bootstrap-server kafka:${PORT_KAFKA_BROKER_INTERNAL} --create --if-not-exists --replication-factor 1 --partitions 1 --topic demo
9393 deploy :
9494 replicas : 0
9595
9696 # Delete Kafka topic.
9797 delete-topic :
98- image : ${KAFKA_IMAGE}
98+ image : docker.io/apache/kafka:4.0.0
9999 networks : [ingestr-demo]
100100 command : /opt/kafka/bin/kafka-topics.sh --bootstrap-server kafka:${PORT_KAFKA_BROKER_INTERNAL} --delete --if-exists --topic demo
101101 deploy :
102102 replicas : 0
103103
104104 # Publish data to Kafka topic.
105105 publish-topic :
106- image : ${KAFKA_IMAGE}
106+ image : docker.io/apache/kafka:4.0.0
107107 networks : [ingestr-demo]
108108 command : /opt/kafka/bin/kafka-console-producer.sh --bootstrap-server kafka:${PORT_KAFKA_BROKER_INTERNAL} --topic demo
109109 deploy :
110110 replicas : 0
111111
112112 # Subscribe to Kafka topic.
113113 subscribe-topic :
114- image : edenhill/kcat:${KCAT_VERSION}
114+ image : docker.io/ edenhill/kcat:1.7.1
115115 networks : [ingestr-demo]
116116 command : kcat -b kafka -C -t demo # -o end
117117 deploy :
@@ -123,23 +123,23 @@ services:
123123
124124 # Create database table in CrateDB.
125125 create-table :
126- image : westonsteimel/httpie
126+ image : docker.io/ westonsteimel/httpie
127127 networks : [ingestr-demo]
128128 command : http "${CRATEDB_HTTP_URL_DOCKER}/_sql?pretty" stmt='CREATE TABLE "kafka_demo" ("payload" OBJECT(DYNAMIC))' --ignore-stdin
129129 deploy :
130130 replicas : 0
131131
132132 # Drop database table in CrateDB.
133133 drop-table :
134- image : westonsteimel/httpie
134+ image : docker.io/ westonsteimel/httpie
135135 networks : [ingestr-demo]
136136 command : http "${CRATEDB_HTTP_URL_DOCKER}/_sql?pretty" stmt='DROP TABLE IF EXISTS "kafka_demo"' --ignore-stdin
137137 deploy :
138138 replicas : 0
139139
140140 # Invoke HTTPie via Docker.
141141 httpie :
142- image : westonsteimel/httpie
142+ image : docker.io/ westonsteimel/httpie
143143 networks : [ingestr-demo]
144144 deploy :
145145 replicas : 0
0 commit comments