diff --git a/stream-applications-integration-tests/pom.xml b/stream-applications-integration-tests/pom.xml
index 8da7055..fd4b158 100644
--- a/stream-applications-integration-tests/pom.xml
+++ b/stream-applications-integration-tests/pom.xml
@@ -16,8 +16,8 @@
 
 	<properties>
 		<java.version>1.8</java.version>
-		<java-functions.version>1.0.0-M4</java-functions.version>
-		<stream-applications.version>3.0.0-M4</stream-applications.version>
+		<java-functions.version>1.0.3-SNAPSHOT</java-functions.version>
+		<stream-applications.version>3.0.2-SNAPSHOT</stream-applications.version>
 		<mariadb-client.version>2.6.2</mariadb-client.version>
 		<test-containers.version>1.15.1</test-containers.version>
 		<maven-checkstyle-plugin.version>3.1.0</maven-checkstyle-plugin.version>
diff --git a/stream-applications-integration-tests/src/test/java/org/springframework/cloud/stream/apps/integration/test/source/http/HttpSourceTests.java b/stream-applications-integration-tests/src/test/java/org/springframework/cloud/stream/apps/integration/test/source/http/HttpSourceTests.java
index a3137b9..dff3ce1 100644
--- a/stream-applications-integration-tests/src/test/java/org/springframework/cloud/stream/apps/integration/test/source/http/HttpSourceTests.java
+++ b/stream-applications-integration-tests/src/test/java/org/springframework/cloud/stream/apps/integration/test/source/http/HttpSourceTests.java
@@ -29,6 +29,7 @@ import org.testcontainers.containers.wait.strategy.Wait;
 import reactor.core.publisher.Mono;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.stream.app.test.integration.AppLog;
 import org.springframework.cloud.stream.app.test.integration.OutputMatcher;
 import org.springframework.cloud.stream.app.test.integration.StreamAppContainer;
 import org.springframework.cloud.stream.app.test.integration.StreamAppContainerTestUtils;
@@ -56,7 +57,7 @@ public abstract class HttpSourceTests {
 				.withEnv("SERVER_PORT", String.valueOf(serverPort))
 				.withExposedPorts(serverPort)
 				.waitingFor(Wait.forListeningPort().withStartupTimeout(DEFAULT_DURATION));
-		source.start();
+		source.withLogConsumer(AppLog.appLog("http")).start();
 	}
 
 	@Autowired
@@ -74,8 +75,8 @@ public abstract class HttpSourceTests {
 		webClient
 				.post()
 				.uri("http://localhost:" + source.getMappedPort(serverPort))
-				.contentType(MediaType.TEXT_PLAIN)
-				.body(Mono.just("Hello"), String.class)
+				.contentType(MediaType.valueOf("application/x-www-form-url-encoded"))
+				.body(Mono.just("Hello".getBytes()), byte[].class)
 				.exchange()
 				.subscribe(r -> {
 					httpStatus.set(r.statusCode());