@gamussa почему голос такой тихий на стриме то ? =)

А что там, зукипер выпилили из Кафки?

Прямо скоро ждать?

Я там потом починил

Очень заходит этот выпуск и начало там где вы обсуждали разные реактивные вещи, и парное программирование, все круто

👍🏻
Старались

еще такой формат будет ? :)

Я в твиттере видел

Подумал неужто прям случилось

Ребят, а кто-то работал с axon для взаимодействия с кафкой?

Да

может такое быть что флуктуация в логике обработки сообщений?

БД тормозит, разные мощности у машин, разная логика для разных сообщений?

Сначала проверь распределение данных по партициям, хеширование несовершенно и вполне может быть, что у тебя одни партиции переполнены, в то время как другие пустуют. Если не это, то проверь байтрейт на все участвующие машины, если сетевая проблема, что случается часто, особенно на облаках, то некоторые воркеры просто физически не получают свои данные с той же скоростью, с которой их получают остальные. И только потом можно грешить на 1) виртуализацию, 2) рантайм и конфигурацию приложения и 3) железо в том порядке, в котором я озвучил. Это из моего личного опыта с такими проблемами.

Хороший доклад, сходите посмотрите кто хочет понять как время работает в Kafka Streams https://www.confluent.io/resources/kafka-summit-2020/the-flux-capacitor-of-kafka-streams-and-ksqldb/

Здравствуйте! https://github.com/housepower/clickhouse_sinker как в работе?

CH же уже сам научился забирать данные из кафки

tableengine=kafka? этож не то

а в чем преимущество sinker-а?