Size: a a a

2020 October 08

MA

Michael Akushsky in pro.kafka
Denis Pavlyuchenko
о, а можно вопрос про кейс. Роутеров мало, или они будут не напрмую в кафку ходить, а через какой-нибудь MQTT Proxy?
роутеров много, уже сейчас это будут десятки тысяч, а в перспективе - многие миллионы
источник

MA

Michael Akushsky in pro.kafka
а в чем проблема ходить напрямую в кафку?
источник

IK

Ilya Kaznacheev in pro.kafka
Коллеги, подскажите, пожалуйста, я могу как-то из топика выбирать сообщения только по определенному ключу, а остальные пропускать?

Кейс такой: сервис пишет результаты работы в выходной топик, при этом есть возможность в качестве ключа указать сервис, который отправил запрос

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

DP

Denis Pavlyuchenko in pro.kafka
Michael Akushsky
а в чем проблема ходить напрямую в кафку?
есть мнение, что есть какой-то адекватынй лимит на количество продюсеров (типо, каждый продюсер вносит доп. расходы на обсуживание). Так что, возможно имеет смысл на нагрузочном стенде убедиться, что нужное количество одновременных продюсеров будет работать с должным уровнем качества
источник

MA

Michael Akushsky in pro.kafka
Denis Pavlyuchenko
есть мнение, что есть какой-то адекватынй лимит на количество продюсеров (типо, каждый продюсер вносит доп. расходы на обсуживание). Так что, возможно имеет смысл на нагрузочном стенде убедиться, что нужное количество одновременных продюсеров будет работать с должным уровнем качества
Это хороший вопрос, но это не наша проблема, внезапно) демон, который будет клиентом кафки - разработка другой конторы, там вообще на С++ это написано) И это всё будет их проблемой, так как это их требование - чтобы всё общение было через кафку
источник

АВ

Алексей Васин... in pro.kafka
Всем привет а spring kafka поддержиает какой-нибудь тип трастора и кейстора кроме jks
источник

АВ

Алексей Васин... in pro.kafka
Например pkcs12
источник

SB

Sergey Bezrukov in pro.kafka
Алексей Васин
Например pkcs12
Попробуйте в конфиге задать ssl.key.store.type: PKCS12 , может сработать
источник

АВ

Алексей Васин... in pro.kafka
да чот не работает так
источник

АВ

Алексей Васин... in pro.kafka
странно конечно, что они дают возможность задать тайп
источник

АВ

Алексей Васин... in pro.kafka
но при этом вроде как кроме jks туда ничего не подставить
источник

АВ

Алексей Васин... in pro.kafka
в инетах ничего не нашел похожего
источник

DM

Dmitri Mumber in pro.kafka
Всем привет!
Кто-нибудь сталкивался с проблемой установки consumer.max.poll.records и consumer.max.poll.interval.ms для (custom) Kafka Connect коннекторов? Коннектор игнорирует любые значения :( Может кто подскажет альтернативы?
Спасибо!
источник

t

terancet in pro.kafka
Всем привет

Киньте в меня, пожалуйста, докладами, про Kafka streams.
На страничке Kafka summit нашёл 3 штуки. Хотелось бы ещё посмотреть
Буду благодарен.
источник

VG

Vik Gamov in pro.kafka
terancet
Всем привет

Киньте в меня, пожалуйста, докладами, про Kafka streams.
На страничке Kafka summit нашёл 3 штуки. Хотелось бы ещё посмотреть
Буду благодарен.
Шта? 3 штуки? А как ты искал?
источник

VG

Vik Gamov in pro.kafka
https://videos.confluent.io/watch/NT7ji1NFK2Rh8TDfyKTpSz? Из последнего. Введение в Kafka streams
источник

t

terancet in pro.kafka
Vik Gamov
Шта? 3 штуки? А как ты искал?
Cmd F “stream”
источник

t

terancet in pro.kafka
А что тогда порекомендуешь из хардкорного?
источник

VG

Vik Gamov in pro.kafka
источник

VG

Vik Gamov in pro.kafka
terancet
А что тогда порекомендуешь из хардкорного?
Matthias Sax all day
источник