DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:51:58.175637 [ 6 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:52:05.177770 [ 4 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:52:12.180081 [ 8 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:52:19.182092 [ 31 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:52:26.184083 [ 30 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:52:33.186477 [ 5 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
2019.08.05 08:52:40.188840 [ 28 ] {} <Error> void DB::StorageKafka::streamThread(): std::exception. Code: 1001, type: cppkafka::HandleException, e.what() = Local: Timed out, version = 19.11.3.11 (official build)
На тесте всё работает норм, возникает только на проде.
(пробовал версии 19.11.3.11 и 19.11.2.7)
пытался откатится на версию 19.8.3.8, но кх не подымается
Кх и кафка в докере.
Интересно почему на тесте всё ок, а на проде не работает?
Может как-то влияет то, что кафка за океаном от кх и надо какую-то опцию подтюнить?
Из кафки ни одного сообщения не доходит?
Обсуждают сегодня