diff --git a/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java b/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java
index 17f04d0b..e6b43160 100644
--- a/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java
+++ b/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java
@@ -48,7 +48,7 @@ public class BatchEventsApplicationTests {
 	
 	@Test
 	public void testExecution() throws Exception {
-		SpringApplication.run(BatchEventsApplication.class, "--server.port=0");
+		SpringApplication.run(BatchEventsApplication.class, "--server.port=0", "--spring.cloud.stream.bindings.output.producer.requiredGroups=testgroup");
 		Assert.assertTrue("The latch did not count down to zero before timeout",
 				jobExecutionLatch.await(60, TimeUnit.SECONDS));
 	}
diff --git a/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties b/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties
index 0e98a419..8921774b 100644
--- a/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties
+++ b/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties
@@ -15,3 +15,4 @@
 #
 
 spring.cloud.stream.bindings.input.destination=job-execution-events
+spring.cloud.stream.bindings.input.group=testgroup