diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java
index dd5bda040..33a5b510c 100644
--- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java
+++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java
@@ -55,13 +55,13 @@ public class PartitionedConsumerTest {
 	private Binder binder;
 
 	@Autowired @Bindings(TestSink.class)
-	private Sink testSource;
+	private Sink testSink;
 
 	@Test
 	@SuppressWarnings("unchecked")
 	public void testBindingPartitionedConsumer() {
 		ArgumentCaptor<Properties> argumentCaptor = ArgumentCaptor.forClass(Properties.class);
-		verify(binder).bindConsumer(eq("partIn"), eq(testSource.input()), argumentCaptor.capture());
+		verify(binder).bindConsumer(eq("partIn"), eq(testSink.input()), argumentCaptor.capture());
 		Assert.assertThat(argumentCaptor.getValue().getProperty(BinderProperties.PARTITION_INDEX), equalTo("0"));
 		Assert.assertThat(argumentCaptor.getValue().getProperty(BinderProperties.COUNT),
 				equalTo("2"));