AU
в какие метрики смотреть?
Size: a a a
2020 December 15
AU
есть и такой и такой
AU
MSK тоже есть
ЮХ
Andrey
У меня вот так
offset.storage.topic=connect-offsets
offset.storage.replication.factor=2
offset.storage.partitions=25
config.storage.topic=connect-configs
config.storage.replication.factor=2
config.storage.partitions=1
status.storage.topic=connect-status
status.storage.replication.factor=2
status.storage.partitions=5
offset.storage.topic=connect-offsets
offset.storage.replication.factor=2
offset.storage.partitions=25
config.storage.topic=connect-configs
config.storage.replication.factor=2
config.storage.partitions=1
status.storage.topic=connect-status
status.storage.replication.factor=2
status.storage.partitions=5
у тебя получается config партиция 1.
У меня так же, ноя все думаю, правильно это или нет))
У меня так же, ноя все думаю, правильно это или нет))
A
Там их миллион, нужен дешборд нормальный в котором все главные метрики выводятся. ну всякие jmx_exporter + prometheus + grafana
A
у тебя получается config партиция 1.
У меня так же, ноя все думаю, правильно это или нет))
У меня так же, ноя все думаю, правильно это или нет))
а для этой настройки можно только одну партицию по доке
ЮХ
О как.
Ок, я не нашел этой информации (или просмотрел).
Спасибо
Ок, я не нашел этой информации (или просмотрел).
Спасибо
VG
Приходите на стрим сегодня https://www.confluent.io/resources/kubernetes-spring-boot-kafka-streams-workshop/
A
Приходите на стрим сегодня https://www.confluent.io/resources/kubernetes-spring-boot-kafka-streams-workshop/
А в записи потом остётся стрим? Когда на k8s будем переходить, хотелось бы глянуть
VG
Andrey
А в записи потом остётся стрим? Когда на k8s будем переходить, хотелось бы глянуть
A
круто, подписался
VG
Andrey
круто, подписался
Ну и на мой подписывайся YouTube.com/viktorgamov
A
Уже :) Кстати, а confluent не занимается реализацией kafka streams фреймворка на других языках? А если конкретно то на Go?
DP
Andrey
Уже :) Кстати, а confluent не занимается реализацией kafka streams фреймворка на других языках? А если конкретно то на Go?
ks
Начни с моего доклада https://youtu.be/nQd209e9eCY
Премного благодарен!
YL
Всем добрый день/вечер. Kafka streams! Есть несколько топиков, которые нужно обогащать данными друг друга, чтобы на выходе получилось нужная запись для дальнейшей обработки. Соответственно, использую цепочку join операций. Для этого сначала нужен "rekey": map, selectKey... Создаются внутренние топики repartition. Под нагрузкой лаг в них растет. Эта проблема решаема? Под нагрузкой показывает не совсем удовлетворительный результат. Думаю KS может быстрее работать.
Топики однопартиционные. Нода одна. Планируется переход на кластер.
Топики однопартиционные. Нода одна. Планируется переход на кластер.
НТ
Добрый день. Подскажите, пожалуйста, как объединить json и файлы данных с помощью kafka?
VG
https://youtu.be/ampmQg33JtY готовность 15 минут
K
Привет
Подскажите нубу какие есть варианты сделать fault tolerant сетап продюсеров в кафку.
То есть есть продюсер, который пишет в кафку. Нужно чтобы если он, продюсер, упал, запись продолжалась.
Есть какие-то стандартные схемы для этого?
Подскажите нубу какие есть варианты сделать fault tolerant сетап продюсеров в кафку.
То есть есть продюсер, который пишет в кафку. Нужно чтобы если он, продюсер, упал, запись продолжалась.
Есть какие-то стандартные схемы для этого?