diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java index 352d3e057..bbd13449c 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java @@ -163,7 +163,6 @@ public final class StreamBridge implements SmartInitializingSingleton { SubscribableChannel resolveDestination(String destinationName, ProducerProperties producerProperties) { SubscribableChannel messageChannel = this.channelCache.get(destinationName); if (messageChannel == null) { - producerProperties.setRequiredGroups(destinationName); messageChannel = new DirectWithAttributesChannel(); this.bindingService.bindProducer(messageChannel, destinationName, false); this.channelCache.put(destinationName, messageChannel);