diff --git a/edge/service/src/main/java/org/eclipse/ditto/edge/service/dispatching/EdgeCommandForwarderActor.java b/edge/service/src/main/java/org/eclipse/ditto/edge/service/dispatching/EdgeCommandForwarderActor.java
index 54b558df0f..4ac3ac542a 100644
--- a/edge/service/src/main/java/org/eclipse/ditto/edge/service/dispatching/EdgeCommandForwarderActor.java
+++ b/edge/service/src/main/java/org/eclipse/ditto/edge/service/dispatching/EdgeCommandForwarderActor.java
@@ -188,14 +188,8 @@ private void forwardToConnectivity(final ConnectivityCommand<?> connectivityComm
                                                 "shard region", withEntityId.getEntityId(),
                                         transformedConnectivityCommand.getType());
 
-                        if (isIdempotent(transformedConnectivityCommand)) {
-                            askWithRetryCommandForwarder.forwardCommand(transformedConnectivityCommand,
-                                    shardRegions.connections(),
-                                    sender);
-                        } else {
-                            shardRegions.connections().tell(transformedConnectivityCommand, sender);
-                        }
-
+                        // don't retry connectivity commands
+                        shardRegions.connections().tell(transformedConnectivityCommand, sender);
                     });
         } else {
             log.withCorrelationId(connectivityCommand)