diff --git a/dynamic-mapping-service/src/main/java/dynamic/mapping/connector/core/client/AConnectorClient.java b/dynamic-mapping-service/src/main/java/dynamic/mapping/connector/core/client/AConnectorClient.java index 85065c7b4..530b94e75 100644 --- a/dynamic-mapping-service/src/main/java/dynamic/mapping/connector/core/client/AConnectorClient.java +++ b/dynamic-mapping-service/src/main/java/dynamic/mapping/connector/core/client/AConnectorClient.java @@ -503,7 +503,10 @@ public void updateActiveSubscriptionInbound(Mapping mapping, Boolean create, Boo } } } + } else { + log.warn("Tenant {} - Mapping {} contains wildcards like #,+ which are not support by connector {}",tenant, mapping.getId(), connectorName); } + } } @@ -525,6 +528,8 @@ public void updateActiveSubscriptionsInbound(List updatedMappings, bool updatedMappings.forEach(mapping -> { Boolean containsWildcards = mapping.subscriptionTopic.matches(".*[#\\+].*"); boolean validDeployment = (supportsWildcardsInTopic() || !containsWildcards); + if(!validDeployment) + log.warn("Tenant {} - Mapping {} contains wildcards like #,+ which are not support by connector {}",tenant, mapping.getId(), connectorName); List deploymentMapEntry = mappingComponent.getDeploymentMapEntry(tenant, mapping.ident); boolean isDeployed = false; if (deploymentMapEntry != null) {