Size: a a a

2020 February 20

EI

Eugene Ivlev in pro.kafka
Ivan Rasikhin
if (shouldReuseSourceTopicForChangelog) {
                   storeBuilder.withLoggingDisabled();
                   topologyBuilder.connectSourceStoreAndTopic(storeBuilder.name(), topicName);
               }
вот кусок кода из стримов который отключает логгирование при оптимизации
А вот этот код так же работает? Что этот connect делает?
источник

IR

Ivan Rasikhin in pro.kafka
кладет source топик в мапу с changelog топиками для определенного стора
источник
2020 February 21

TC

Trisha Chetani in pro.kafka
I wanted to pair on Kafka for advanced topic like stream , data flow (somebody who has a bit experience and can help me)
источник

VG

Vik Gamov in pro.kafka
Trisha Chetani
I wanted to pair on Kafka for advanced topic like stream , data flow (somebody who has a bit experience and can help me)
Do you have any specific questions? What specifically you want to learn
источник

ЮБ

Юрий Бадальянц in pro.kafka
Ivan Rasikhin
это да, я сколько не пытался хорошо разобрать исходники стримов, никак нормаьлно не получается)
Я позапускал. И вот что обнаружил:
1. Этот флаг у меня всегда false, даже если включена оптимизация.
2. Если выключить ченжлог, то этот флаг всё ещё false. А это значит, что при рестартах восстановления состояния не будет.
источник

ЮБ

Юрий Бадальянц in pro.kafka
Вот такие пироги
источник

ЮБ

Юрий Бадальянц in pro.kafka
Ага, всё оказалось ещё интереснее. Оказывается, пропсы нужно передавать не только при создании инстанса KafkaStreams, но и при вызове метода build на топологии. Потому что проперти topology.optimization применяется только в момент вызова build.
Что интересно — никаких другие пропсов не используется при вызове build. Почему нельзя было разнести отдельно разные виды конфигурации (на уровне стрима и на уровне топологии) — не ясно. "Удобное апи"!
источник

SB

Sergei Beilin in pro.kafka
Коллеги, кто использует MySQL source connector - расскажите, пожалуйста, о вашем опыте.
источник

SB

Sergei Beilin in pro.kafka
Да, ещё опыт с php интересен.
источник

N

Nikolay in pro.kafka
Когда будет сходка кафкаводов ? Уже весна скоро.
источник

SB

Sergei Beilin in pro.kafka
Nikolay
Когда будет сходка кафкаводов ? Уже весна скоро.
В Стокгольме - 5 марта!
источник

N

Nikolay in pro.kafka
Мне хочется в Москве. Что бы не летать. В Авито вот тоже душевно было.
источник

C

Constantine in pro.kafka
источник

TC

Trisha Chetani in pro.kafka
@gamussa I wanted to create a data flow , like Wikipedia have changes in article and I could get the event for it and process the event and save in non relation database
источник

AK

Ann Kazantseva in pro.kafka
Ребята, а никто, случайно, не использует SFTP CSV Source Connector?...
источник

A

Anatoly Soldatov in pro.kafka
Nikolay
Мне хочется в Москве. Что бы не летать. В Авито вот тоже душевно было.
Пока точно не знаем даты, но весной точно митап будет :)
источник

A

Anatoly Soldatov in pro.kafka
Sergei Beilin
В Стокгольме - 5 марта!
Не хочешь к нам в гости прилететь?)
источник

SB

Sergei Beilin in pro.kafka
Anatoly Soldatov
Не хочешь к нам в гости прилететь?)
"уж лучше вы к нам" (с)
источник

EK

Eduard Korolev in pro.kafka
kafka+php - кто использует, как организована архитектура? Интересует демон консумера и сколько их? Т.е если вы создаете 10 топиков, то вы поднимаете 10 воркеров? или 1 топик на все и в топике есть поле type_id и 1 демон который обслуживает все и в зависимости от типа запускает разные воркеры?
источник

GM

Gleb Mekhrenin in pro.kafka
поставили рест или вебсокет прокси между кафкой и пхп написанный на нормальном яп
источник