Size: a a a

2020 November 13

V

VladMl in pro.kafka
Aleksei Lebedev
UI нотификации через вебсокеты. Есть несколько инстансов аппа, которые держут коннекшны от вебсокетов, и есть топик, в который летят нотификаций. Хочется иметь возможность отправить нотификации, которые пришли, пока соединение с вебсокетом было разорвано (упал коннекшн и переконнектился через небольшое время). Иметь несколько партишнов не получится, потому что мы не знаем на каком именно инстансе аппа получатель нотификации, а значит должны слать на все.

выглядит вообще как довольно стандартная задача, если без окна, а вот с ним чё-то не могу понять как лучше.
А коннекшены по инстансам как распределяются? Если можно сделать распределение по хешу ключа например то и продюсер может точно так-же роутить нотификейшены
источник

ЧП

Чёрный Плащ... in pro.kafka
у меня есть идея реализовать коннектор
сделать я его сделаю, и буду использовать. А как поделиться с людьми, чтобы он попал на https://www.confluent.io/hub/ и помогал людям?
какие требования, какая процедура?
или не нашёл, или плохо искал - ткните носом

заранее спасибо
источник

DD

Dmitry Dobrynin in pro.kafka
Чёрный Плащ
у меня есть идея реализовать коннектор
сделать я его сделаю, и буду использовать. А как поделиться с людьми, чтобы он попал на https://www.confluent.io/hub/ и помогал людям?
какие требования, какая процедура?
или не нашёл, или плохо искал - ткните носом

заранее спасибо
привет. на гитхабе опубликуй сырцы, билд скрипты и документацию - народ сможет пользоваться.
источник

ЧП

Чёрный Плащ... in pro.kafka
ну эт понятно
источник

ЧП

Чёрный Плащ... in pro.kafka
ну ладно. ближе к продакшн использованию вернусь к теме выкладки. сейчас в любом случае рано ещё
источник

AZ

Alexander Zaitsev in pro.kafka
доброго времени суток. Пытаюсь влиться в message-based подход коммуникации между сервисами. И никак не могу понять, как принято решать вот такое:

Есть сервис A. При обработке сообщения ему необходимо:
1) Получить некоторую инфу от сервисов B и C
2) На основании этой инфы он уже что-то сделает и отошлёт какое-нибудь сообщение.

Как такое делать при помощи обычного синхронного способа - понятно. Я же хочу организовать сообщение только через message queue.

Собственно вопрос - как такое принято делать? Спасибо :)
источник

AZ

Alexander Zaitsev in pro.kafka
Alexander Zaitsev
доброго времени суток. Пытаюсь влиться в message-based подход коммуникации между сервисами. И никак не могу понять, как принято решать вот такое:

Есть сервис A. При обработке сообщения ему необходимо:
1) Получить некоторую инфу от сервисов B и C
2) На основании этой инфы он уже что-то сделает и отошлёт какое-нибудь сообщение.

Как такое делать при помощи обычного синхронного способа - понятно. Я же хочу организовать сообщение только через message queue.

Собственно вопрос - как такое принято делать? Спасибо :)
из того, что мне в голову приходит, это только для ответов от B и C создать по отдельному reply топику, которые сервис A по месту слушает, агрегирует от них ответы и дальше продолжает работу
источник

AL

Aleksei Lebedev in pro.kafka
VladMl
А коннекшены по инстансам как распределяются? Если можно сделать распределение по хешу ключа например то и продюсер может точно так-же роутить нотификейшены
произвольно распределяются, как кубер сроутит
источник

V

VladMl in pro.kafka
Aleksei Lebedev
произвольно распределяются, как кубер сроутит
тогда наверное лучше реализовать DLQ. Если не смог отослать то ложим нотификейшн в DLQ и потом пытаемся отослать позже
источник

AL

Aleksei Lebedev in pro.kafka
VladMl
тогда наверное лучше реализовать DLQ. Если не смог отослать то ложим нотификейшн в DLQ и потом пытаемся отослать позже
Порядок доставки сообщений конкретному клиенту важен
источник

SE

Sergei Egorov in pro.kafka
источник

S🐉

Sergey 🐉 Rublev in pro.kafka
🎉🍾🔥 новость крутая, посмотрим, потрогаем
источник

GK

Gregory Koshelev in pro.kafka
Если зайти на страничку сравнения с Kafka, то брешут и не краснеют: Read Replicas у Kafka есть уже очень давно.
источник

GK

Gregory Koshelev in pro.kafka
Eliminate Zookeeper® и Native Prometheus Support – так ли это важно?
источник

S🐉

Sergey 🐉 Rublev in pro.kafka
зависимость от Зукипера и сама Кафка почти удалила у себя
источник

GK

Gregory Koshelev in pro.kafka
Тоже верно. В ближайшем будущем и это станет неактуально.
источник

I

Ivan in pro.kafka
latency percentile
источник

SE

Sergei Egorov in pro.kafka
Интересно, а тут https://twitter.com/lazin?s=21 не сидит?)
источник

SE

Sergei Egorov in pro.kafka
Evgeny ха!
источник

N

Nazar in pro.kafka
Gregory Koshelev
Eliminate Zookeeper® и Native Prometheus Support – так ли это важно?
Это лучше, чем ничего из коробки
источник