KL
quartz тоже вроде как поддерживает
Size: a a a
2020 March 05
ЮХ
Всем привет.
Есть необходимость вычитывать данные из таблицы Oracle и складывать их в kafka.
У кого был опыт поделитесь... Книга, статья.
На что стоит обратить внимание?
Можно ли использовать для этих меропрятий коннектор в докере?
Для начала планирую сделать простой вариант без СDC, чисто DML запросами.
Есть необходимость вычитывать данные из таблицы Oracle и складывать их в kafka.
У кого был опыт поделитесь... Книга, статья.
На что стоит обратить внимание?
Можно ли использовать для этих меропрятий коннектор в докере?
Для начала планирую сделать простой вариант без СDC, чисто DML запросами.
SN
Ребята из Леруа похожую задачу решали, на митапе рассказывали https://www.youtube.com/watch?v=dxmj4GxKI5Q
ЮХ
Ребята из Леруа похожую задачу решали, на митапе рассказывали https://www.youtube.com/watch?v=dxmj4GxKI5Q
Сяп, пошел погружаться)
NV
Добрый день, подскажите пожалуйста, можно ли заставить кафка-брокер рекламировать одну и ту же ноду по нескольким адресам? Запускаем кафку в докере, кажется что копать нужно в сторону
KAFKA_ADVERTISED_LISTENERS, но дальше чет понятия не имеемAZ
Добрый день, подскажите пожалуйста, можно ли заставить кафка-брокер рекламировать одну и ту же ноду по нескольким адресам? Запускаем кафку в докере, кажется что копать нужно в сторону
KAFKA_ADVERTISED_LISTENERS, но дальше чет понятия не имеемв документации вроде понятно, но тут дополнительно все пояснено https://rmoff.net/2018/08/02/kafka-listeners-explained/
И
в основном это относится к девелоперским кластерам, т.к, завязывать маинтенанс или перегруз на одном кластере с другими кластерами в проде не очень хочется
AZ
а бестпрактис какой на этот счёт?
best practice в отношении zookeeper - don't share!
I
best practice в отношении zookeeper - don't share!
Спасибо!
AS
Привет. Подскажите, можно ли реализовать работу с топиком кафки так, чтобы в нём отбрасывались сообщения по ключу, если в топике уже есть сообщение с таким же ключом?
AS
Т.е. что-то вроде compactify log, только наоборот - нужны не самые новые, а самые старые записи.
И
может это?
AS
не идемпотентность (тут понятно, читал), а именно разные сообщения, с разным payload, но одинаковым ключом.
1-е например в 10 утра, второе в 15, оставить нужно только первое.
1-е например в 10 утра, второе в 15, оставить нужно только первое.