NN
Size: a a a
2020 January 29
NN
понял, спасибо
NK
добрый день! Кто тут админ?)
VG
добрый день! Кто тут админ?)
А какой вопрос? В шапке канала написано
2020 January 30
СГ
Всем привет! Кто-нибудь сталкивался с необходимостью писать hdfs-sink коннектором в керберизированный хадуп, когда керберизированная кафка живёт в другом домене и трастов между доменами нет?)
AU
AZ
Сергей Григоров
Всем привет! Кто-нибудь сталкивался с необходимостью писать hdfs-sink коннектором в керберизированный хадуп, когда керберизированная кафка живёт в другом домене и трастов между доменами нет?)
в принципе керберос вас не ограничивает тут, вы можете сколько угодно доменов в одном китабе иметь, но надо поглядеть как jaasconfig двойной передать коннекту
СГ
в принципе керберос вас не ограничивает тут, вы можете сколько угодно доменов в одном китабе иметь, но надо поглядеть как jaasconfig двойной передать коннекту
Да вот в том то и дело. Была бы возможность без переписывания задать в настройках коннектора jaas было бы легче, а так принципал, китаб и все..
AZ
Сергей Григоров
Да вот в том то и дело. Была бы возможность без переписывания задать в настройках коннектора jaas было бы легче, а так принципал, китаб и все..
если вы клиент конфлюент - это как раз такой вопрос для которых стоит использовать поддержку :)
СГ
если вы клиент конфлюент - это как раз такой вопрос для которых стоит использовать поддержку :)
Нет, к сожалению. Придётся лезть грязными ручками в исходники коннектора)
AZ
Сергей Григоров
Нет, к сожалению. Придётся лезть грязными ручками в исходники коннектора)
в качестве быстрого фикса (и мне не верится что я это рекомендую сам :)) можно попробовать нафаню, там можно разным процессорам давать разные настройки
СГ
Ещё такой вопросик.. HDFS3 sink коннектор взведется на confluent 5.0.1?
AB
Всем привет!
Как мониторите работу source-коннекторов, кроме кол-ва тасков и статуса коннектора?
Интересует конкретно наполнение целевого топика.
Как мониторите работу source-коннекторов, кроме кол-ва тасков и статуса коннектора?
Интересует конкретно наполнение целевого топика.
VD
@gamussa, ты как-то говорил, что все новые фичи пилятся на Java, на Scala осталось только легаси.
Нет планов или обсуждений по закапыванию Скалы в кафке?
Нет планов или обсуждений по закапыванию Скалы в кафке?
VG
@gamussa, ты как-то говорил, что все новые фичи пилятся на Java, на Scala осталось только легаси.
Нет планов или обсуждений по закапыванию Скалы в кафке?
Нет планов или обсуждений по закапыванию Скалы в кафке?
Работает - не трогай.
NA
Всем привет, столкнулся с кафкой и возник такой вопрос - как найти сообщение содержащие определенный текст? Нужно просто проверить приходило ли оно или нет. Первое чем воспользовался это
bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic message --from-beginning | grep "388556"Но может есть более адекватный способ?
AZ
Всем привет, столкнулся с кафкой и возник такой вопрос - как найти сообщение содержащие определенный текст? Нужно просто проверить приходило ли оно или нет. Первое чем воспользовался это
bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic message --from-beginning | grep "388556"Но может есть более адекватный способ?
в принципе вы близки к оптимальному решению, можно только запустить по одному процессу на каждую партицию)