diff --git a/integration-tests/README.md b/integration-tests/README.md
index 1d00e56612e..9502786dec7 100644
--- a/integration-tests/README.md
+++ b/integration-tests/README.md
@@ -258,7 +258,7 @@ of the integration test run discussed above. Running these tests requires the us
 their own Cloud. 
 
 Currently, the integration test supports Amazon Kinesis, Google Cloud Storage, Amazon S3, and Microsoft Azure.
-These can be run by providing "kinesis-index", "gcs-deep-storage", "s3-deep-storage", or "azure-deep-storage" 
+These can be run by providing "kinesis-index", "kinesis-data-format", "gcs-deep-storage", "s3-deep-storage", or "azure-deep-storage" 
 to -Dgroups for Amazon Kinesis, Google Cloud Storage, Amazon S3, and Microsoft Azure respectively. Note that only
 one group should be run per mvn command.
 
diff --git a/integration-tests/script/docker_compose_args.sh b/integration-tests/script/docker_compose_args.sh
index ea61e88d287..7fcc30f9f7f 100644
--- a/integration-tests/script/docker_compose_args.sh
+++ b/integration-tests/script/docker_compose_args.sh
@@ -69,7 +69,13 @@ getComposeArgs()
       echo "-f ${DOCKERDIR}/docker-compose.yml"
     fi
   else
+    if [ "$DRUID_INTEGRATION_TEST_GROUP" = "kinesis-data-format" ]
+    then
+      # default + with override config + schema registry container
+      echo "-f ${DOCKERDIR}/docker-compose.override-env.yml -f ${DOCKERDIR}/docker-compose.schema-registry.yml"
+    else
     # with override config
-    echo "-f ${DOCKERDIR}/docker-compose.override-env.yml"
+      echo "-f ${DOCKERDIR}/docker-compose.override-env.yml"
+    fi
   fi
 }
diff --git a/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractKinesisIndexingServiceTest.java b/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractKinesisIndexingServiceTest.java
index 25dd871c673..5854a623444 100644
--- a/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractKinesisIndexingServiceTest.java
+++ b/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractKinesisIndexingServiceTest.java
@@ -117,6 +117,11 @@ public abstract class AbstractKinesisIndexingServiceTest extends AbstractStreamI
             "%%STREAM_PROPERTIES_KEY%%",
             "endpoint"
         );
+        spec = StringUtils.replace(
+                spec,
+                "%%SCHEMA_REGISTRY_HOST%%",
+                StringUtils.format("http://%s", config.getSchemaRegistryInternalHost())
+        );
         return StringUtils.replace(
             spec,
             "%%STREAM_PROPERTIES_VALUE%%",