Size: a a a

2021 January 25

NC

Nigerian Currywurst in pro.kafka
Если первый не отвечает - спрашивает следующие
источник

В

Вячеслав in pro.kafka
А, вот так.. Тогда может и прокатит, но надёжной конфигурацией это точно назвать нельзя :)
источник

В

Вячеслав in pro.kafka
А главное - а он точно переключится при падении первого кластера? :)
источник

NC

Nigerian Currywurst in pro.kafka
Вячеслав
А главное - а он точно переключится при падении первого кластера? :)
Не знаю
источник

A

Anton in pro.kafka
Вячеслав
А главное - а он точно переключится при падении первого кластера? :)
А нельзя это как то протестировать? Что-то типа POC
Поднять два контейнера с кафкой и один с продюсером, в котором указать настройки выше. А потом один контейнер убить
источник

В

Вячеслав in pro.kafka
Я бы всё же поискал готовые решения для фэйловера кафки между кластерами. Наверняка их есть.
источник
2021 January 26

NC

Nigerian Currywurst in pro.kafka
Что почитать про multitenancy и кафку?
источник

V

Vadim in pro.kafka
org.apache.kafka.common.errors.RecordTooLargeException: The message is 2565072 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
источник

V

Vadim in pro.kafka
max.request.size  достаточно поменять?
источник

VA

Vektor AB in pro.kafka
Вечер добрый. Каким образом в стримах можно разделить отправку по топикам по условию? При этом в каждом топике своя модель. Branch, как я понял, для одной модели, но разных топиков.
источник

VG

Vik Gamov in pro.kafka
Nigerian Currywurst
Что почитать про multitenancy и кафку?
Да ничего особенного из коробки нет. Читай про quotes.
источник

VG

Vik Gamov in pro.kafka
Vektor AB
Вечер добрый. Каким образом в стримах можно разделить отправку по топикам по условию? При этом в каждом топике своя модель. Branch, как я понял, для одной модели, но разных топиков.
resultStream
   .filter(this::success)
   .to(transactionSuccessConfiguration.getName());

resultStream
   .filterNot(this::success)
   .to(transactionFailedConfiguration.getName());
источник

VG

Vik Gamov in pro.kafka
В метод to можно передать Serde через Produced.with
источник
2021 January 27

ЧП

Чёрный Плащ... in pro.kafka
Vadim
org.apache.kafka.common.errors.RecordTooLargeException: The message is 2565072 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
вообще, насколько я помню, для передачи сообщений больше 1МБ приходится координированно настройки менять на и продюсере и на брокере, и на консьюмере. в сумме что-то около 8 или 10 настроек получилось.
если просто изменить одну настройку - будет другая ошибка :)
по крайней мере, так было в версии 2.0.0
источник

V

Vadim in pro.kafka
Вот тоже думаю
источник

IK

Ilya Kaznacheev🥤 in pro.kafka
Коллеги, тут услышал такое, что создавать топики по-умолчанию в кафке - это плохая практика?
Это правда?
Как работаете с созданием новых топиков?
источник

VG

Vik Gamov in pro.kafka
Ilya Kaznacheev🥤
Коллеги, тут услышал такое, что создавать топики по-умолчанию в кафке - это плохая практика?
Это правда?
Как работаете с созданием новых топиков?
да
источник

VG

Vik Gamov in pro.kafka
Ilya Kaznacheev🥤
Коллеги, тут услышал такое, что создавать топики по-умолчанию в кафке - это плохая практика?
Это правда?
Как работаете с созданием новых топиков?
AdminClient API и консольные комманды
источник

IK

Ilya Kaznacheev🥤 in pro.kafka
У меня такой сценарий: сервисы сами создают себе топики при первом подключении, но сейчас я сделал с явным указанием количества партиций и всего такого. То есть эта операция выполняется в процессе деплоя, а не мануально. Это тоже плохо?
источник

VG

Vik Gamov in pro.kafka
Ilya Kaznacheev🥤
У меня такой сценарий: сервисы сами создают себе топики при первом подключении, но сейчас я сделал с явным указанием количества партиций и всего такого. То есть эта операция выполняется в процессе деплоя, а не мануально. Это тоже плохо?
Нормально. Любое явное создание топиков это норм. Плохо когда топик создается при первом обращении консьюмера или продьюсера с дефолтными настройками
источник