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

Чтобы сделать самостоятельное обучение по Kafka еще более интересным, сегодня мы предлагаем вам простой тест по основам конфигурации потребителя в Apache Kafka.

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

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

Открытый тест по конфигурации Kafka-потребителей

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

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

 ConsumerSettings

 ConsumerConfig

 Properties

 ConsumerProperties

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

 StringSerializer

 Serializer

 ByteSerializer

 String

3. Какой элемент отвечает за десериализацию ключей сообщений?

 serializerOfKey

 key.serializer

 serializer

 keySerializer

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

 submitHeartbeat()

 submitReady()

 startHeartbeat()

 startHeartbeatThreadIfNeeded()

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

private fun kafkaConsumer(): KafkaConsumer<String, String> {

val properties = Properties()

properties[«bootstrap.servers»] = «localhost:9092»

properties[«group.id»] = «kafka-example»

properties[«key.deserializer»] = «org.apache.kafka.common.serialization.StringDeserializer»

properties[«value.deserializer»] = «org.apache.kafka.common.serialization.StringDeserializer»

 

return KafkaConsumer(properties)

}

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

 за публикацию сообщений

 за создание потока отправки сообщений

 за базовую настройку конфигурации Kafka-потребителя

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

 fetchPositions()

 update()

 updateFetchPositions()

 updatePositions()

7. За что отвечает потребитель в Kafka?

 за получение сообщений

 за публикацию сообщений

 за доставку сообщений

 за создание канала отправки сообщений

8. Какой элемент отвечает за создание группы для объединения нескольких потребителей?

 groupId

 group

 group.id

 id.group

9. Какой метод отвечает за повторное соединение с группой?

 joinGroup()

 joinGroupIfNeeded()

 join()

 fecthAndJoin()

10. За что отвечает элемент bootstrap.servers?

 за настройку подключения к серверам Kafka-кластера

 за настройку Kafka-кластера

 за выделение транзитного брокера в кластере

 за настройку Zookeeper

 Загрузка …

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

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

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

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

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