diff --git a/docker/docker-compose.kafkacluster.yml b/docker/docker-compose.kafkacluster.yml
index 3506017..b3f005e 100755
--- a/docker/docker-compose.kafkacluster.yml
+++ b/docker/docker-compose.kafkacluster.yml
@@ -129,7 +129,7 @@ services:
       PORT: 9021
 
   ksql-datagen:
-    image: confluentinc/ksqldb-examples:7.1.0
+    image: confluentinc/ksqldb-examples:7.1.2
     hostname: ksql-datagen
     container_name: ksql-datagen
     depends_on: