интервью: Я слышал, что вы владеете Кафкой.,Тогда я проверю тебя. Вопрос: Не паникуйте, просто скажите это.,Неважно, ошибаетесь ли вы😊。。。__кЧтобы поделиться технологией в форме [интервью с интервьюером], этот выпуск называется «Серия Кафки», если вам интересно, подписывайтесь на меня.❤️

Интервьюер: Вы знаете высшую точку Кафки?

Текущий уровень воды является смещением копии.,записал текущийМаксимальное смещение зафиксированного сообщения。

Вот и все,KafkaНовости только вВсе копии разделовПосле синхронизации сообщения,Вот и всеПоданныйновости。

Копия раздела будет основана накопия ведущего разделаОбеспечен высокий уровень воды,избегатьНе отправленоновостипотребляется。

Интервьюер думает...

Интервьюер: Не могли бы вы рассказать мне, как Кафка обеспечивает надежность сообщений?

Да, окей.

На стороне брокера,В основном используетсяРазделенная многокопийная архитектура,Чтобы сообщение не потерялось.

Kafkaдля каждого раздела кластераКопия босса,Будетn（Коэффициент копирования）индивидуальныйbrokerПосле копирования машины,генерироватькопия подписчика。

В то же время, если Копия Машина босса не работает, копия подписчика会选举成为新的Копия босса。

Наличие нескольких резервных копий разделов является гарантией надежности хранения сообщений.

Интервьюер думает...

Интервьюер: А как насчет других производителей и потребителей?

Да, и да, есть еще надежность со стороны производителей и потребителей.

1. Со стороны производителя

1. предоставилack = allЭтот видМеханизм подтверждения отправки。То есть только в том случае, если сообщение успешноНаписать во все копииназад,Это новости Поданный,Многократные резервные копии сообщений гарантированы.
2. ack = все, если не получится,Производители могуткпродолжатьПопробуйте еще разОтправить сообщение。

2. Со стороны потребителя

1. Когда потребители потребляют,Будет израсходовано в соответствии со смещением,Гарантированопоследовательность сообщений。
2. Он будет отправлен синхронно после потребления.、асинхронныйзафиксировать смещение,Гарантировано Сообщение неПовторное потребление。

Интервьюер думает...

Интервьюер: Что, если потребление Кафки будет накапливаться?

В этом случае нам нужно взглянуть на это как с точки зрения брокера, так и с точки зрения потребителя.

1. Слова брокера

1. Каждая тема разделена на несколько разделов и обрабатывается разными брокерами.,хотетьРазумно распределяйте количество разделовулучшитьBrokerновостивычислительная мощность。например3индивидуальныйBroker2индивидуальный Раздел,Можно изменить на 3 брокера и 3 раздела.
2. Также возможнокМасштабироватьBrokerкластер

2. Что говорят потребители

1. Может увеличить количество бытового обслуживания
2. зафиксировать смещениечас,Можетк Измените синхронную отправку наАсинхронная отправка,Для сокращения времени ожидания синхронизации Брокера

Интервьюер думает...

Интервьюер: эммммм, ты знаешь контроллер Kafka?

Да, я знаю. Контроллер на самом деле является брокером,Однако он также несет ответственность за выборы.лидер раздела。

То есть в Копии босса所在的Раздел失效назад,Контроллер выбирает новые реплики разделов.Копия босса。

Интервьюер чешет затылок и продолжает просматривать ваше резюме... вам придется подумать о контрольных пунктах, которые вам непонятны😰

Продолжение следует. . . . . .

Хорошо, на сегодня это все, и мы продолжим в следующем выпуске [Серия Kafka].

Творить непросто, поэтому вы можете ставить лайки, собирать и подписываться, чтобы поддержать его. Ваша поддержка — самая большая мотивация для моего творчества.❤️