Я наблюдаю, что экземпляр потребителя не обнаружил ошибку во время регистрации потребителя, даже если для экземпляра потребителя не истекло время ожидания. Использование Confluent API.
Ниже приведены шаги для этого отрицательного тестирования:
Запуск скрипта для регистрации потребителя.
Топология Кафки: 3 экземпляра ZK (где 2 ZK - фиктивное значение) и 1 кластер узла (один экземпляр узла rest-proxy & broker).
Когда выполняется скрипт для регистрации потребителя, отмените скрипт и перезапустите его.
Видел, что для последнего зарегистрированного потребителя возвращается ошибка Instance not found. Но в журналах по прошествии нескольких мс для этого запроса на регистрацию потребителя указывается 200 OK [имя потребителя в общих журналах ниже: CGStress_TEST111111111111111_6].
[2018-08-28 09: 05: 48,411] ИНФОРМАЦИЯ http://localhost:8082/v1/consumer/CGStress_TEST111111111111111_5 Служба: TransacationId: 5 EntityId: ed_1 Авторизовано: true Разрешено: true (io.confluent.kafkarest.resources.SecurityRestrictions)
{ "X-Nssvc-ServiceID": нулевой, "Тип": "API", "X-Nssvc-CustomerID": нулевой, "Клиент-IP": "127.0.0.1", "Тяжесть": "INFO",» X-Cws-Transactionid ":" 5 "," message ": {" request ": {" content-length ": 81," method ":" POST "," time ":" 2018-08-28 09:05 : 48,409" , "URI": "мр / v1 / потребитель / CGStress_TEST111111111111111_5", "субъект-идентификатор": "ed_1", "пользователь-агент": "Python-запросов / 2.11.1"}, "ответ": { "status_code": 200, "time": "2018-08-28 09: 05: 48.412"}}}
[2018-08-28 09: 05: 48,412] INFO 127.0.0.1 - - [28 / Aug / 2018: 09: 05: 48 +0000] "POST / mr / v1 / consumer / CGStress_TEST111111111111111_4 HTTP / 1.1" 200 205 19 (io.confluent.rest-utils.requests)
[2018-08-28 09: 05: 48,420] INFO http://localhost:8082/mr/v1/consumer/CGStress_TEST111111111111111_6 Служба: TransacationId: 6 EntityId: ed_1 Авторизовано: true Разрешено: true (io.confluent.kafkarest.resources.SecurityRestrictions)
{ "X-Nssvc-ServiceID": нулевой, "Тип": "API", "X-Nssvc-CustomerID": нулевой, "Клиент-IP": "127.0.0.1", "Тяжесть": "INFO",» X-Cws-Transactionid ":" 6 "," message ": {" request ": {" content-length ": 81," method ":" POST "," time ":" 2018-08-28 09:05 : 48,419" , "URI": "мр / v1 / потребитель / CGStress_TEST111111111111111_6 ", "сущность-идентификатор": "ed_1", "пользователь-агент": "Python-запросов / 2.11.1"} , "response": {" status_code": 404, "error_response": {"message": "Экземпляр получателя не найден.", "error": 40403} , "time": "2018-08 -28 09: 05: 48.421 "}}}
[2018-08-28 09: 05: 48,423] INFO 127.0.0.1 - - [28 / Aug / 2018: 09: 05: 48 +0000] "POST / mr / v1 / consumer / CGStress_TEST111111111111111_5 HTTP / 1.1" 200 205 15 (io.confluent.rest-utils.requests)
[2018-08-28 09: 05: 48,431] INFO 127.0.0.1 - - [28 / Aug / 2018: 09: 05: 48 +0000] "POST / mr / v1 / consumer / CGStress_TEST111111111111111_6 HTTP / 1.1" 404 61 13 (io.confluent.rest-utils.requests)
[2018-08-28 09: 05: 49,299] ПРЕДУПРЕЖДЕНИЕ Время ожидания сеанса клиента не было получено от сервера в 1501 мс для идентификатора сеанса 0x0 (org.apache.zookeeper.ClientCnxn)
[2018-08-28 09: 05: 49,300] INFO Время ожидания сеанса клиента не было получено от сервера в 1501 мс для идентификатора сеанса 0x0, закрытие соединения с сокетом и попытка переподключения (org.apache.zookeeper.ClientCnxn)
[2018-08-28 09: 05: 49,400] ИНФОРМАЦИЯ Открытие соединения сокета с сервером localhost / 0: 0: 0: 0: 0: 0: 0: 1: 32181. Не будет пытаться аутентифицироваться с использованием SASL (неизвестная ошибка) (org.apache.zookeeper.ClientCnxn)
[2018-08-28 09: 05: 49,400] INFO Соединение с сокетом установлено для localhost / 0: 0: 0: 0: 0: 0: 0: 1: 32181, инициирующий сеанс (org.apache.zookeeper.ClientCnxn)
[2018-08-28 09: 05: 49,403] INFO Установление сеанса завершено на сервере localhost / 0: 0: 0: 0: 0: 0: 0: 1: 32181, sessionid = 0x1657f54045b00f3, согласованное время ожидания = 6000 (org.apache .zookeeper.ClientCnxn)
[2018-08-28 09: 05: 49,403] Изменено состояние INFO zookeeper (SyncConnected) (org.I0Itec.zkclient.ZkClient)
[2018-08-28 09: 05: 49,404] INFO [CGStress_TEST111111111111111_6_UbuntuNTP-1535447146187-7b4d0350], запуск автоматического коммиттера каждые 60000 мс (kafka.consumer.ZookeeperConsumerConnector){ "X-Nssvc-ServiceID": нулевой, "Тип": "API", "X-Nssvc-CustomerID": нулевой, "Клиент-IP": "127.0.0.1", "Тяжесть": "INFO",» X-CWS-TransactionID ":" 6" , "сообщение": { "запрос": { "Content-Length": 81, "метод": "POST", "время": "2018-08-28 09: 05: 46,172" , "URI": "/ CGStress_TEST111111111111111_6", "сущность-идентификатор мр / v1 / потребитель": "ed_1", "пользователь-агент": "Python-запросов / 2.11.1"}, "ответ ": {" status_code ": 200," time ":" 2018-08-28 09: 05: 49.405 "}}}
[2018-08-28 09: 05: 49,409] INFO 127.0.0.1 - - [28 / Aug / 2018: 09: 05: 46 +0000] "POST / mr / v1 / consumer / CGStress_TEST111111111111111_6 HTTP / 1.1" 200 124 3239 (io.confluent.rest-utils.requests)
root @ UbuntuNTP: ~ / CloudServices / MsgRelay #
Это что-то связанное с добавленным экземпляром zk-заглушки?