A
Size: a a a
2020 November 16
A
Zellox просто я даже и не знаю что вам ответить на ваш вопрос, так как это и плюс и минус кафки
плюс что позволяет скейлить независимо запись без единых точек создания заторов
раскидывание по партициям с кастомным партишинером используется для сегментирования данных (например к ksql вроде как через них джойны проходят, всегда знаешь что в указанной партиции данные изолированы)
минусы: кафка это не топив в контексте того же rabitmq, так как порядок сообщений только в пределах партиции, а не глобально
плюс что позволяет скейлить независимо запись без единых точек создания заторов
раскидывание по партициям с кастомным партишинером используется для сегментирования данных (например к ksql вроде как через них джойны проходят, всегда знаешь что в указанной партиции данные изолированы)
минусы: кафка это не топив в контексте того же rabitmq, так как порядок сообщений только в пределах партиции, а не глобально
Z
спасибо за развернутый ответ
GK
https://www.youtube.com/watch?v=A_yUaPARv8U - вот тут подробный разбор, как оно всё работает и почему.
AS
Доброго времени суток!
Кто-нибудь подключал собственную JAAS реализацию аутентификатора?
Кто-нибудь подключал собственную JAAS реализацию аутентификатора?
AS
Добрый день, подскажите, есть ли способ сбросить офсет для активной группы потребителей?
Только если все клиенты группы отключены!
sudo /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group [groupbane] --topic [topicname] --reset-offsets --to-offset [offset-number] --execute
Сброс для группы [groupname] и топика [topicname] оффсета до [offset-number]
sudo /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group [groupbane] --topic [topicname] --reset-offsets --to-offset [offset-number] --execute
Сброс для группы [groupname] и топика [topicname] оффсета до [offset-number]
JS
Только если все клиенты группы отключены!
sudo /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group [groupbane] --topic [topicname] --reset-offsets --to-offset [offset-number] --execute
Сброс для группы [groupname] и топика [topicname] оффсета до [offset-number]
sudo /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group [groupbane] --topic [topicname] --reset-offsets --to-offset [offset-number] --execute
Сброс для группы [groupname] и топика [topicname] оффсета до [offset-number]
Про это в курсе, спасибо, вопрос именно про активную
AS
Про это в курсе, спасибо, вопрос именно про активную
Если активную то мне пока известен способ только насильно отключать клиентов. Обычно они переподключаются потом. Но это мой опыт, если продакшен, не рекомендую такое делать
JS
Если активную то мне пока известен способ только насильно отключать клиентов. Обычно они переподключаются потом. Но это мой опыт, если продакшен, не рекомендую такое делать
Для тестов. А принудительно каким способом?