Соединение Eclipse Ditto Forward время от времени терпит неудачу

Question

Я связал Eclipse hono с Eclipse, используя API Connectivity. Когда я его настроил, все работает нормально. Однако через некоторое время переадресация соединения не удалась. Когда я получаю метрики, я получаю следующий ответ:

{
    "?": {
        "?": {
            "type": "connectivity.responses:aggregatedResponse",
            "status": 200,
            "connectionId": "<connectionId>",
            "responsesType": "connectivity.responses:retrieveConnectionMetrics",
            "responses": {
                "connectivity-7cc7b5dc4c-6nn59": {
                    "type": "connectivity.responses:retrieveConnectionMetrics",
                    "status": 200,
                    "connectionId": "<connectionId>",
                    "connectionMetrics": {
                        "connectionStatus": "open",
                        "connectionStatusDetails": "Connected at 2019-03-19T08:28:53.211Z",
                        "inConnectionStatusSince": "2019-03-19T08:28:53.211Z",
                        "clientState": "CONNECTED",
                        "sourcesMetrics": [],
                        "targetsMetrics": [
                            {
                                "addressMetrics": {
                                    "gw/{{ thing:namespace }}/{{ thing:id }}": {
                                        "status": "failed",
                                        "statusDetails": "Producer closed at 2019-03-19T21:00:16.466Z",
                                        "messageCount": 2048,
                                        "lastMessageAt": "2019-03-19T21:00:05.361Z"
                                    }
                                },
                                "publishedMessages": 4070
                            }
                        ]
                    }
                }
            }
        }
    }
}

Я проверял журналы в указанное время, но не получаю никаких ошибок. Журналы, которые я публикую здесь, являются последними до и первым после указанной временной отметки (2019-03-19T21:00:16.466Z).

2019-03-19 21:00:11,771 DEBUG [ID:AMQP_NO_PREFIX:TelemetrySenderImpl-42872] o.e.d.s.c.m.a.AmqpPublisherActor akka://ditto-cluster/system/sharding/connection/7/tenant_aloxy_consumer-aloxy-forward/pa/$a/c1/amqpPublisherActor3
 - Message JmsTextMessage { org.apache.qpid.jms.provider.amqp.message.AmqpJmsTextMessageFacade@9bc051af } sent successfully.
2019-03-19 21:01:11,733 DEBUG [ID:AMQP_NO_PREFIX:TelemetrySenderImpl-42872] o.e.d.s.c.m.a.AmqpClientActor akka://ditto-cluster/system/sharding/connection/1/tenant_aloxy_consumer-aloxy/pa/$a/c1 - Inbound message: JmsInboundMessageDispatch { sequence = 38885, messageId = TelemetrySenderImpl-42873, consumerId = ID:a4925b59-1bb4-4cd8-9151-96ad422c36df:1:1:1 }

Хотя уровни журналов для всех служб Ditto настроены на отладку, я не получаю никакой полезной регистрации.
Кто-нибудь из вас имеет представление о том, как я могу получить регистрацию, чтобы исследовать эту проблему, или, что еще лучше, иметь представление о том, что может быть проблема и как ее исправить?

Когда я удаляю соединение и воссоздаю его, все снова работает как положено. Может быть, то же самое может сделать это под капотом автоматически?

ОБНОВИТЬ
При получении соединения через API я получаю следующий ответ (включая свойство failoverEnabled со значением true). Это также указывает на то, что соединение использует AMQP 1.0. Используемый брокер - Enmasse.

{
    "?": {
        "?": {
            "type": "connectivity.responses:retrieveConnection",
            "status": 200,
            "connection": {
                "id": "<connectionId>",
                "name": null,
                "connectionType": "amqp-10",
                "connectionStatus": "open",
                "uri": "amqp://<consumer>:<password>@<amqp-host>:5672",
                "sources": [],
                "targets": [
                    {
                        "address": "gw/{{ thing:namespace }}/{{ thing:id }}",
                        "topics": [
                            "_/_/things/twin/events?filter=exists(features/alp)"
                        ],
                        "authorizationContext": [
                            "<auth-context>"
                        ]
                    }
                ],
                "clientCount": 1,
                "failoverEnabled": true,
                "validateCertificates": true,
                "processorPoolSize": 5,
                "tags": []
            }
        }
    }
}

Answer 1

Eclipse Ditto выполняет автоматическое аварийное переключение, если настроено на это (см. https://www.eclipse.org/ditto/basic-connections.html - свойство failoverEnabled в модели). Однако может случиться так, что это было улучшено с версии 0.8.0, которую вы используете. Команда Ditto в настоящее время работает над выпуском 0.9.0-M1, который будет содержать улучшенное поведение переподключения.

Соединение с Eclipse Hono автоматически переподключается? Вы описали, что время от времени происходит переадресация соединения. Какая технология (брокер и т. Д.) Является конечной точкой для этого gw/{{ thing:namespace }}/{{ thing:id }} адрес?