В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

pro.kafka

1649 membersпожаловаться на группу
2020 March 20

AE

Anton Evseev in pro.kafka
Коллеги, привет. Подскажите пожалуйста, брокеры не коннектятся в zk, ошибка «Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)» Как с этим бороться?
источник
12:22пожаловаться#1

MB

Mikhail Butalin in pro.kafka
Я в лёгком замешательстве...
А из 2ой кафки что kafka.consumer убрали из JMX чтоли????
источник
12:24пожаловаться#2

MB

Mikhail Butalin in pro.kafka
источник
12:31пожаловаться#3

MB

Mikhail Butalin in pro.kafka
короче, на JMX брокера нет этой метрики. Она в самом консьюмере
источник
12:37пожаловаться#4

MB

Mikhail Butalin in pro.kafka
И еще вопрос!
источник
14:33пожаловаться#5

MB

Mikhail Butalin in pro.kafka
Я тут столкнулся со странной непоняткой.
У меня  kafka-consumer-groups.sh --list ничего не выдаёт.
Это как так?
Консьюмеры есть в кафке...
источник
14:35пожаловаться#6

MB

Mikhail Butalin in pro.kafka
кафка 2.2.1
источник
14:35пожаловаться#7

MB

Mikhail Butalin in pro.kafka
Разьве партиция в топике - это консьюмер?
источник
14:44пожаловаться#8

ὦ

ὦan in pro.kafka
FIY - если запускать кафку в докере (образ confluent) то при поднятии докер затирает часть настроек - по крайней мере точно затирает KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR и ставит его 3
источник
15:10пожаловаться#9

N

Nenormalniy in pro.kafka
ὦan
FIY - если запускать кафку в докере (образ confluent) то при поднятии докер затирает часть настроек - по крайней мере точно затирает KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR и ставит его 3
FYI, наверное
источник
15:16пожаловаться#10

ὦ

ὦan in pro.kafka
А можно как-то c кафки больше затребовать стектрейс?
Не особо информативная ошибка Caused by: java.lang.ClassCastException: CreditProductMessage cannot be cast to su.moneycare.service.precalc.kafka.model.CreditProductMessage
Учитывая что я перетащил авро модель из проекта и она валидная
источник
19:09пожаловаться#11

МИ

Морозов Иван in pro.kafka
Посоветуйте, пожалуйста, какой-нибудь общедоступный дашборд для кафка коннекторов в графану, чтобы мониторить воркеры, коннекторы, таски
источник
19:24пожаловаться#12

r

romλn in pro.kafka
Морозов Иван
Посоветуйте, пожалуйста, какой-нибудь общедоступный дашборд для кафка коннекторов в графану, чтобы мониторить воркеры, коннекторы, таски
У конфлюэнта есть Хельм чарты со всей платформой и там из коробки прометеус и графана с дашбордами
источник
19:29пожаловаться#13

ὦ

ὦan in pro.kafka
Кто-нибудь сталкивался с ошибкой Could not find class CreditProductMessage specified in writer's schema whilst finding reader's schema for a SpecificRecord
Отправляю в топик сообщение через авро и пытаюсь прочитать его в другом сервисе
Генерировал классы на основании одной и той же схеме
Вот консьюмер
Настройки https://pastebin.com/YnADEFHZ
Из ответов нашел https://github.com/confluentinc/schema-registry/issues/670
источник
20:12пожаловаться#14

ὦ

ὦan in pro.kafka
Я решил - надо было сделать specific.avro.reader: false
источник
20:21пожаловаться#15
2020 March 22

IR

Ivan Rasikhin in pro.kafka
Привет всем, кто нибудь сталкивался с такими ошибками в кафке:
[2020-03-22 07:20:40,505] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Retrying leaderEpoch request for partition card-event-9 as the leader reported an error: UNKNOWN_SERVER_ERROR (kafka.server.ReplicaFetcherThread)
?
источник
10:32пожаловаться#16

IR

Ivan Rasikhin in pro.kafka
просто спами по разным топикам/партициям
источник
10:33пожаловаться#17

IR

Ivan Rasikhin in pro.kafka
[2020-03-22 07:14:29,206] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 0: java.net.SocketTimeoutException: Failed to connect within 30000 ms. (org.apache.kafka.clients.FetchSessionHandler)
источник
10:33пожаловаться#18

IR

Ivan Rasikhin in pro.kafka
плюс такое
источник
10:33пожаловаться#19

Y

Yuriy in pro.kafka
Ivan Rasikhin
Привет всем, кто нибудь сталкивался с такими ошибками в кафке:
[2020-03-22 07:20:40,505] INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Retrying leaderEpoch request for partition card-event-9 as the leader reported an error: UNKNOWN_SERVER_ERROR (kafka.server.ReplicaFetcherThread)
?
Может разные конфиги у брокеров?
источник
13:51пожаловаться#20