Size: a a a

2020 November 10

SB

Sergey Bezrukov in pro.kafka
Denis Larionov
Пока мне приходится определять нужно сообщение, разбирая его. А хочется сразу из топика
Извините, но вас как-то сложно понять, туманно объясняете. У вас в сообщении есть поле "адресат" и вы хотите сделать разделение по нему что ли?  Или в одном топике перемешаны сообщения разных типов?
источник

DL

Denis Larionov in pro.kafka
Адресат разный
источник

DL

Denis Larionov in pro.kafka
Хочу их разделить по топикам
источник

ER

Evgeny Rachlenko in pro.kafka
Вячеслав
Ну да, все верно. Readiness на кафку + dependencies на зависимые сервисы.
Можешь показать пример как на сервисе правильно прописывать зависимость от кафки ?
источник

SB

Sergey Bezrukov in pro.kafka
Можно по партициям топика разделить, используя адресата в качестве ключа
источник

SB

Sergey Bezrukov in pro.kafka
Можно наверное чего-нибудь на KSQL накостылить
источник

ЧП

Чёрный Плащ... in pro.kafka
А просто на KStream реализовать отправку в зависимости от содержимого хоть на тысячу топиков разве нельзя?
источник

VG

Vik Gamov in pro.kafka
Denis Larionov
к чему вопрос? Зачем мы это делаем? -> бизнес задача.
Я уверен что бизнес задача звучит как-то иначе. Поддерживаю предыдущего Ога оратора - зачем столько
источник

DL

Denis Larionov in pro.kafka
Много датчиков, принимают информацию. Хочется доставлять сообщение на конкретный датчик
источник

SB

Sergey Bezrukov in pro.kafka
Denis Larionov
Много датчиков, принимают информацию. Хочется доставлять сообщение на конкретный датчик
А внутри датчика спринг? Бахато :-)  А инфа нужна только конкретному датчику или есть варианты?
источник

DL

Denis Larionov in pro.kafka
Только конкретному
источник

SB

Sergey Bezrukov in pro.kafka
ХЗ как так в кафке сделать, в rabbitmq вроде можно так - при подписке указать критерий фильтрации (гуглить rabbitmq message routing)
источник

VG

Vik Gamov in pro.kafka
Может кафку действительно не нужна. Может лучше mqtt какой-нибудь взять
источник

SD

Serg D. in pro.kafka
Denis Larionov
Только конкретному
На кафке это плохая идея, как мне кажется. Вы можете теоретически повесить каждый датчик на отдельную партицию. Но при большом кол-ве датчиков вам потребуется очень жирный кластер.
источник

SD

Serg D. in pro.kafka
Пусть уж лучше датчики poll'ят какой-нибудь обычный рест-сервис =)
источник

DL

Denis Larionov in pro.kafka
Vik Gamov
Может кафку действительно не нужна. Может лучше mqtt какой-нибудь взять
Может. Наверное так и сделаем
источник

I

Ivan in pro.kafka
А предыдущие были от кого?
источник

A

Artjom Kalita in pro.kafka
от конфлюента в августе
источник

VG

Vik Gamov in pro.kafka
Ivan
А предыдущие были от кого?
источник

I

Ivan in pro.kafka
👍🏼
источник