From 6ef016367c9986ff953c3f20e2b312b405e888aa Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 18 May 2020 16:44:23 +0200 Subject: [PATCH] Remove setting required groups --- .../org/springframework/cloud/stream/function/StreamBridge.java | 1 - 1 file changed, 1 deletion(-) 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);