Confluent-Kafka Ошибка "Не найден экземпляр получателя", даже если время ожидания экземпляра не истекло
Я наблюдаю, что экземпляр Потребителя не обнаружил ошибку во время регистрации потребителя, даже если для экземпляра потребителя не истекло время ожидания. Использование 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":null,"Type":"API","X-Nssvc-customerid":null,"Client-IP":"127.0.0.1","Severity":"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] ИНФОРМАЦИЯ http://localhost:8082/mr/v1/consumer/CGStress_TEST111111111111111_6 Служба: TransacationId: 6 EntityId:ed_1 Авторизовано: true Разрешено: true (io.confluent.kafkarest.re sources.SecurityRestrictions) {"X-Nssvc-serviceid": null, "Type": "API", "X-Nssvc-customerid": null, "Client-IP": "127.0.0.1", "Severity": " INFO " "X-CWS-TransactionID":"6","сообщение": { "запрос": { "Content-Length": 81, "метод":"POST","время":" 2018-08- 28 09: 05: 48.419 "," uri ":" mr / v1 / consumer / CGStress_TEST111111111111111_6 ","entity-id":"ed_1","user-agent":"python-запросы / 2.11.1 "}," ответ ":{" код_состояния ": 404," ошибка_ответа ":{" сообщение ":" экземпляр получателя не найден. "," ошибка ": 40403}," время ":" 2018-08-28 09: 05: 48.421 " }}} [2018-08-28 09: 05: 48,423] ИНФОРМАЦИЯ 127.0.0.1 - - [28 / авг / 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 мс для sessionid 0x0 (org.apache.z ookeeper.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:49403] ИНФО изменения состояния зоопарка (SyncConnected) (org.I0Itec.zkclient.ZkClient) [2018-08-28 09:05:49,404] INFO [CGStress_TEST111111111111111_6_UbuntuNTP-1535447146187-7b4d0350], запуск автоматического коммиттера каждые 60000 мс (kafka.consumer.ZookeeperConsumerConnector) {"тип X-Nssvll:" null: "null:" null ": служба" null ":" null "": служба "null": "null": "null" "service" "API", "X-Nssvc-CustomerID": нулевой, "Клиент-IP": "127.0.0.1", "Тяжесть": "INFO", "X-Cws-TransactionID":"6","сообщение": {"request":{"content-length": 81, "method":"POST","time": "2018-08-28 09: 05: 46.172", "uri": "mr / v1 / consumer / CGStress_TEST111111111111111_6 " "сущность-идентификатор":"ed_1","пользователь-агент": "Python-запросов /2.11.1"},"ответ": { "status_code": 200, "время":"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/customer / CGStress_TEST111111111111111_6 HTTP / 1.1 "200 124 3239 (io.confluent.rest-utils.requests) root @ UbuntuNTP: ~ / CloudServices / MsgRelay #
Это что-то связанное с добавлением инстанса zk?