Или фрагментируются так, что кафка не в восторге

Хотя по идее кафке-то чего, к ней уже собранное в исходном виде все должно прийти

А саму Кафку ты потюнил предварительно?

В локальной сети ведь все работает

Я также подумал про jvm, но блин..

🤷‍♂

В пределах одного хоста виртуализации, насколько я понял. Возможно, там эмулируется сеть в 10 Гбит/с, поэтому и работает?

Неет

Две разные вмки, внутри хетцнера. Уж хз физически один хост или нет

Все что с приставками max и bytes я накрутил с запасом. По локалке эти контейнеры на разных хвостах отрабатывают как АК-47. Файл тестовый 60 мб за секунду.  Короче даже ls не успеваю написать

Уже лежит все

Но если консьюмер поднян на серваке, который за овпн, который натится на другую вмку в том же облаке, То хрен. смотрю в кондукторе, хз может это не по "пацански))", но пофиг как, хоть через интернет, хоть через овпн если к кафке конектится докер с локального сервака, консьюмер появляется, тикает лаг, как будто пытается забрать. И все. Ничего не происходит. Логи молчат даже в дебаге

Стойкое ощущение что кто-то где-то пролезть не может. Но до этого уровня я ещё не спустился, сегодня проверял все возможные пути воспроизведения, завтра похоже надо ваершарком лезть )

Потюнь sysctl

Единственное на что обратил внимание, что при попытке в очередной раз протолкнуть сообщение по нужной схеме, Кафка начала сыпать в лог типо Ява аут оф мемори. При этом и сам кондуктор стал дико лагать. Вот отсюда ещё закралась мысль , что возможно если Яве приходится как-то фрагментить пакеты, или чанки я хз что там, то при отправке куда-то здоровенного файла, она может упираться в память. Но память я не накручивал

Хотя с другой стороны, откуда она знает что пакет не из локалки, если на овпн серваке нат

Докинь хипа, это ж изи

Ну вот этого и не успел попробовать, спешил )

Но спасибо за советы

Весело. Ты прям как я гитлаб из исходников под 32 разряда сборка)))