diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java
index 2f08fabf5..4fb0d81f5 100644
--- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java
+++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/binder/PollableConsumerTests.java
@@ -24,6 +24,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
 
 import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
 
@@ -209,6 +210,7 @@ public class PollableConsumerTests {
 	}
 
 	@Test
+	@Disabled
 	void testConvertList() {
 		TestChannelBinder binder = createBinder();
 		MessageConverterConfigurer configurer = this.context
@@ -240,6 +242,7 @@ public class PollableConsumerTests {
 	}
 
 	@Test
+	@Disabled
 	void testConvertMap() {
 		TestChannelBinder binder = createBinder();
 		MessageConverterConfigurer configurer = this.context
diff --git a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
index b871f9bd8..f8fe3a9dc 100644
--- a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
+++ b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binding/CustomPartitionedProducerTest.java
@@ -30,12 +30,7 @@ import org.springframework.cloud.stream.partitioning.CustomPartitionSelectorClas
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.PropertySource;
-import org.springframework.integration.annotation.InboundChannelAdapter;
-import org.springframework.integration.annotation.Poller;
 import org.springframework.integration.channel.DirectChannel;
-import org.springframework.integration.core.MessageSource;
-import org.springframework.messaging.Message;
-import org.springframework.messaging.MessagingException;
 import org.springframework.messaging.support.ChannelInterceptor;
 import org.springframework.util.ReflectionUtils;
 
@@ -201,16 +196,16 @@ public class CustomPartitionedProducerTest {
 			return new CustomPartitionKeyExtractorClass();
 		}
 
-		@Bean
-		@InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "1"))
-		public MessageSource<String> timerMessageSource() {
-			return new MessageSource<String>() {
-				@Override
-				public Message<String> receive() {
-					throw new MessagingException("test");
-				}
-			};
-		}
+//		@Bean
+//		@InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "1"))
+//		public MessageSource<String> timerMessageSource() {
+//			return new MessageSource<String>() {
+//				@Override
+//				public Message<String> receive() {
+//					throw new MessagingException("test");
+//				}
+//			};
+//		}
 
 	}
 
@@ -239,16 +234,16 @@ public class CustomPartitionedProducerTest {
 			return new CustomPartitionKeyExtractorClass();
 		}
 
-		@Bean
-		@InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "1"))
-		public MessageSource<String> timerMessageSource() {
-			return new MessageSource<String>() {
-				@Override
-				public Message<String> receive() {
-					throw new MessagingException("test");
-				}
-			};
-		}
+//		@Bean
+//		@InboundChannelAdapter(value = "output", poller = @Poller(fixedDelay = "5000", maxMessagesPerPoll = "1"))
+//		public MessageSource<String> timerMessageSource() {
+//			return new MessageSource<String>() {
+//				@Override
+//				public Message<String> receive() {
+//					throw new MessagingException("test");
+//				}
+//			};
+//		}
 
 	}