Как создать потребителя Apache Kafka с помощью Conduktor?

Kafka Consumers привыкла считывать данные из темы и помнить, что тема снова идентифицируется по ее имени. Таким образом, потребители достаточно умны, и они будут знать, из какого брокера читать и из каких разделов читать. А в случае сбоев брокера потребители знают, как восстанавливаться, и это опять-таки хорошее свойство Apache Kafka. Теперь данные для потребителей будут считываться по порядку в каждом разделе . Теперь, пожалуйста, обратитесь к изображению ниже. Итак, если мы посмотрим на Потребителя, потребляющего из Topic-A/Partition-0 , то он сначала прочитает сообщение 0, затем 1, затем 2, затем 3, вплоть до сообщения 11. Если другой потребитель читает из двух разделов, например Раздел-1 и Раздел-2, будет читать оба раздела по порядку. Это может быть с ними одновременно, но внутри раздела данные будут считываться по порядку, но между разделами, у нас нет возможности сказать, какой из них будет считан первым или вторым, и поэтому нет упорядочивание по разделам в Apache Kafka .

Note: Please read this article, Apache Kafka Consumer, to know more about Kafka Consumer.

Итак, в этой статье мы собираемся обсудить, как создать потребитель Apache Kafka с помощью Conduktor. Кратко говоря о Conduktor, Conduktor — это полнофункциональное собственное настольное приложение, которое подключается непосредственно к Apache Kafka, чтобы обеспечить прозрачность управления кластерами, приложениями и микросервисами Kafka. В конечном итоге это помогает компаниям максимально эффективно использовать имеющиеся у них инженерные ресурсы и сводит к минимуму потребность в глубоком внутреннем опыте.

Пошаговая реализация

Шаг 1. Создайте Apache Kafka Producer с помощью Conduktor

Пожалуйста, прочтите эту статью, Как создать Apache Kafka Producer с помощью Conduktor, и создайте своего производителя Apache Kafka, чтобы мы могли использовать те же данные.

Шаг 2: Откройте Conduktor и нажмите на название темы, из которой вы хотите использовать данные, как показано на изображении ниже.

Шаг 3: Теперь нажмите кнопку «Использовать данные» , как показано на изображении ниже.

Шаг 4: Затем откроется всплывающее окно, и здесь вы можете использовать данные на основе времени и смещения . Пожалуйста, обратитесь к изображению ниже. Так что это ваш выбор, на каком основании вы хотите использовать данные.

Итак, здесь мы выбираем «Начать с самого начала» (самое раннее) . И нажмите на кнопку Пуск .

Как вы можете видеть на изображении ниже, потребление данных из темы было запущено.

И если вы нажмете кнопку «Подробности» , вы увидите все подробности, такие как название темы, раздел, смещение и т. Д. Нажав кнопку «Стоп» , потребление будет остановлено.

Вы также можете увидеть разделы, нажав кнопку «Показать разделы» . Пожалуйста, обратитесь к изображению ниже.

Вы также можете отобразить свои данные в табличной форме, нажав на значок. Пожалуйста, обратитесь к изображению ниже.