Вдруг кому понадобится по теме event sourcing (eventsourcing) on kafka слайды, где хорошо расписано все по полочкам, плюсы и минусы.
https://www.slideshare.net/gschmutz/kafka-as-an-event-store-is-it-good-enough

А как с state store убедится, что там не stale data? Если например мы сообщение уже записали в кафку, а в state store оно еще не дошло, в результате при его чтении мы получаем устаревшую инфу. Как это решается?

[
 {
   "topic": "test-topic",
   "key": null,
   "value": {
     "REQUEST_ID": 120471431,
     "ADDRESS": 11728870001,
     "CITY_ID": 1,
     "CREATE_TIME": 1586755569000,
     "UPDATE_TIME": null,
     "CLOSING_CLASS": {
       "string": "Авария"
     },
     "KEY_COMMENT": null,
     "COMPANY_ID": null,
     "EVENT_TAG": null,
     "SERVICE": null,
     "UL_AGREEMENT_NUMBER": null,
     "FL_AGREEMENT_NUMBER": {
       "string": "590019636285"
     },
     "PLAN_GROUP": null
   },
   "partition": 0,
   "offset": 0
 }
]

Всем привет. Подскажите плз нубу, что я делаю не так. Пользователь с ACL "ACCESS * на все ресурсы" не может листить топики.

conduktor, например, вот такое говорит при создании топика

Разобрался, добавил прав через CLI - попустило. Похоже resourceType=TOPIC ,*, patternType=PREFIXED не работает, а работает resourceType=TOPIC, name=*, patternType=LITERAL.
До этого добавлял через Conduktor

State store локален (часть KStreams приложения). сначала пишется в state store, потом в кафку

Кто-нибудь проходил сертификацию на кафку? Хочется послушать стоит ли и в чем профит (кроме как ЧСВ потешить)

так consumer group то с брокера никуда деться не должен

О! Здорово, что тему подняли. То есть если я делаю в стриме агрегацию, то она локальная и запустить пару приложений для распределеной нагрузки не получится. Верно?

Кто-то опять не читал мат часть

Видимо да) поделишься куда смотреть?

https://youtu.be/FrfPbB3A9p4 где-то в районе 13:23

👍 благодарю

не забываем про стрим сегодня

https://twitter.com/gamussa/status/1248646767354220545?s=21

Вчера уснул, извиняюсь. Будет возможность подсказать?

pk.fields=REQUEST_ID может case sentivie?

Тоже об этом думал, пробовал менять, но не реагирует

а что за формат сообщения? avro?

это какая фича кафка коннекта. Не углублялся еще в эту сторону