Обмен технологиями

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Оглавление

Основы Кафки

1. Каковы возможности использования Кафки? Каковы сценарии использования?

2.Что означают ISR и AR в Kafka? Что означает масштабирование ISR?

3. Что означают HW, LEO, LSO, LW и т. д. в Kafka?

4. Как Кафка отражает последовательность сообщений?

5. Знаете ли вы, что такое разделитель, сериализатор и перехватчик в Kafka? Каков порядок обработки между ними?

6. Как выглядит общая структура клиента-производителя Kafka?

7. Сколько потоков используется для обработки в клиенте-производителе Kafka? В чем различия?

8. Каковы недостатки в дизайне старого потребительского клиента Scala от Kafka?

9. Правильно ли это предложение: «Если количество потребителей в группе потребителей превышает тематический раздел, некоторые потребители не смогут потреблять данные». Если верно, есть ли какой-нибудь хак?

10. Какие ситуации могут вызвать повторное употребление?

При каких обстоятельствах утечка информации будет воспринята?

12.KafkaConsumer не является потокобезопасным, так как же реализовать многопоточное потребление?

13. Кратко опишите отношения между потребителями и потребительскими группами.

14. Когда вы используете kafka-topics.sh для создания (удаления) темы, какую логику будет выполнять Kafka?

15.Можно ли увеличить количество разделов темы? Если есть возможность, то как его увеличить? Если нет, то почему?

16.Можно ли уменьшить количество разделов темы? Если возможно, как его можно уменьшить? Если нет, то почему?

17. Как выбрать подходящее количество разделов при создании темы?

Продвинутая глава Какфа

1. Какие внутренние темы есть у Кафки на данный момент и каковы их характеристики? Какова роль каждого?

2. Что такое приоритетная копия? Какую особую функцию он имеет?

3. Откуда у Кафки понятие распределения разделов?Кратко опишите общий процесс и принципы

4. Кратко опишите структуру каталогов журналов Kafka.

5. Какие индексные файлы есть в Kafka?

6. Если я укажу смещение, как Kafka найдет соответствующее сообщение?

7. Если я укажу временную метку, как Kafka найдет соответствующее сообщение?

8. Расскажите о своем понимании хранения журналов Kafka.

1. По времени

2. В зависимости от размера журнала

3. На основе начального смещения бревна.

9. Расскажите о своем понимании метода сжатия журналов Kafka#

10. Расскажите о своем понимании основного хранилища Kafka.

11. Поговорим о принципе работы задержки Кафки.

12 Давайте поговорим о роли контроллера Kafka

13.Каковы недостатки в дизайне старого потребительского клиента Scala от Kafka?

14. В чем заключается принцип ребалансировки потребления? (Подсказка: координатор потребителей и координатор группы потребителей)

15.Как реализована идемпотентность в Кафке?

Кафка Продвинутый

1. Как транзакции реализуются в Kafka?

2.Что означает недействительная копия? Каковы меры противодействия?

3. При нескольких копиях процесс эволюции HW и LEO в каждой копии.

4.Какие улучшения Kafka сделал с точки зрения надежности?

5.Почему Kafka не поддерживает разделение чтения и записи?

6. Как реализовать очередь задержки в Kafka

7. Как реализовать очередь недоставленных писем и очередь повторов в Kafka?

8. Как провести аудит сообщений в Kafka?

9. Как создать трассировку сообщений в Kafka?

10. Как рассчитать лаг? (Обратите внимание на разницу между состояниями read_uncommitted и read_committed)

11.На какие показатели Кафки нужно ориентироваться?

12. Какие особенности Kafka позволяют ему иметь такую ​​высокую производительность?

1. Раздел

2. Уменьшите накладные расходы при передаче по сети.

3. Последовательное чтение и письмо.

4. Технология нулевого копирования

5. Отличный механизм хранения файлов.

---

Основы Кафки

1. Каковы возможности использования Кафки? Каковы сценарии использования?

Система сообщений: И Kafka, и традиционные системы обмена сообщениями (также называемые промежуточным программным обеспечением для сообщений) имеют такие функции, как развязка системы, резервное хранилище, сокращение пикового трафика, буферизация, асинхронная связь, масштабируемость и возможность восстановления. В то же время Kafka также предоставляет функции гарантии последовательности сообщений и ретроактивного потребления, которые трудно достичь в большинстве систем обмена сообщениями.

Система хранения: Kafka сохраняет сообщения на диске, что эффективно снижает риск потери данных по сравнению с другими системами, основанными на хранении в памяти. Именно благодаря функции сохранения сообщений и механизму множественного копирования Kafka мы можем использовать Kafka в качестве системы долговременного хранения данных. Нам нужно только установить для соответствующей политики хранения данных значение «постоянно» или включить функцию сжатия журнала темы. Вот и все.

Платформа потоковой обработки: Kafka не только предоставляет надежный источник данных для каждой популярной платформы потоковой передачи, но также предоставляет полную библиотеку классов потоковой передачи, таких как окна, соединения, преобразования, агрегации и другие операции.