10 вопросов на знание основ архитектуры потребителя Kafka: открытый интерактивный тест для начинающих

Чтобы сделать самостоятельное обучение по Kafka еще более интересным, сегодня мы предлагаем вам простой тест по основам архитектуры Kafka-потребителей, включая особенности создания и работы с ними.

Тест по основам архитектуры потребителя Kafka для новичков

Для тех, кто начинает самостоятельное обучение по Apache Kafka, мы предлагаем простой интерактивный тест по этой стриминговой платформе. Проверьте свои знания и ответьте на 10 вопросов на знание основ архитектуры Kafka-потребителей. Ответы на эти вопросы мы разбирали в статье про структуру потребителя Kafka здесь. Подробно изучить темы, упоминаемые в тесте, вы сможете вы сможете на практических курсах по Kafka в нашем лицензированном учебном центре обучения и повышения квалификации ИТ-специалистов в Москве.

Выбирайте из предложенных вариантов ответов тот, который считаете верным. Правильный ответ вы узнаете после того, как нажмете кнопку ОТПРАВИТЬ. Успехов!

1. Какое свойство отвечает за десериализацию ключей получаемых потребителем сообщений?

 key.deserializer

 key.message.deserializer

 message.deserializer

 consumer.deserializer

2. Какой метод отвечает за подписку потребителя на топик Kafka?

 subscribe_to_topic()

 subscribe()

 getSubscribe()

 getActualTopic()

3. Какой класс отвечает за задание базовой конфигурации Kafka-потребителя?

 Properties

 ConsumerProperties

 ConsumerConfig

 Property

4. Какой метод используется потребителем для получения сообщений из Kafka-топика?

 pollMessage()

 receive()

 getMessage()

 poll()

5. Какое свойство отвечает за создание группы потребителей?

 group.id

 consumer.id

 consumer.group

 group.consumer.id

6. Какой тип принимают значения получаемых сообщений при десериализации?

 string array

 char array

 char

 string

7. Какой класс отвечает за создание экземпляра Kafka-потребителя?

 Consumer

 KafkaConsumer

 ConsumerObject

 ClassKafkaConsumer

8. За что отвечает следующий фрагмент кода:

try {

while (true) {

ConsumerRecords<String, String> records = consumer.poll(100);

for (ConsumerRecord<String, String> record : records) {

log.debug(«topic = %s, partition = %d, offset = %d,

customer = %s, country = %s\n»,

record.topic(), record.partition(), record.offset(),

record.key(), record.value());

int updatedCount = 1;

if (custCountryMap.countainsValue(record.value())) {

updatedCount = custCountryMap.get(record.value()) + 1;}

custCountryMap.put(record.value(), updatedCount)

JSONObject json = new JSONObject(custCountryMap);

System.out.println(json.toString(4)); }}

} finally {

consumer.close(); }

 за создание соединения потребителя с топиком в Kafka-кластере

 за получение сообщений Kafka-потребителем

 за создание Kafka-потребителя

 за обновление топика с сообщениями

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

 цикл for с фиксированным числом итераций

 бесконечный цикл опроса

 бесконечное условие

 условие с множественным выбором switch-case

10. Какой тип принимают объекты (ключи сообщений) при десериализации?

 integer array

 float

 string

 integer

 Загрузка …

Стоит отметить, что данный тест не является профессиональным экзаменом. Однако, такое небольшое упражнение поможет новичкам, которые самостоятельно изучают стриминговый брокер Kafka, пытаясь разобраться с огромным объемом новой информации, систематизировать ее и применить к решению практических задач. Также мы подготовили для вас серию тестов по отдельным разделам Apache Kafka. Например, проверить свои знания по основам отправки сообщений в Kafka вы можете здесь.

Детально освоить Apache Kafka на профессиональном уровне в качестве администратора Big Data кластеров, разработчика распределенных приложений и прочих прикладных областях Data Science вы сможете на практических курсах по Kafka в нашем лицензированном учебном центре обучения и повышения квалификации ИТ-специалистов в Москве:

• Администрирование кластера Kafka
• Kafka Streams для разработчиков
• Интеграция Apache Kafka для разработчиков
• Администрирование кластера Arenadata Streaming Kafka

Записаться на курс

Смотреть раcписание