Cookbook: java kafka producer example — простой пример

Эта статья представляет собой описание самого простого и примитивного клиента отправки сообщение на сервер Kafka с самой простой (дефолтной) конфигурацией.

Статья, нацелена на проверку работы Java Kafka Producer Example. Минимум объяснений, архитектуры и настроек необходимых для работы из коробки.  Хотите более подробную информацию по Kafka — Вам сюда.

Пример проверен при следующих условиях:

  1. JDK не менее чем 1.8
  2. Kafka 2.6.0
  3. Дефолтные настройки Kafka и ZooKeeper

Полный список статей по теме тут.

Заходите в наш телеграмм канал — Enterprise Stack Helper! Делитесь опытом или задавайте вопросы, если что-то непонятно.

Репозитории с примерам из статей по способам аутентификаци и авторизации https://github.com/BlockWit/kafka-security-examples.

 

Пример java Kafka prudecer example

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

Maven проект на Java

Сам проект есть на github — https://github.com/BlockWit/kafka-security-examples. Код самого примера  тут https://github.com/BlockWit/kafka-security-examples/blob/master/src/main/java/com/blockwit/kafka/security/examples/cookbook/JavaKafkaProducerExample.java. Код независим от остальных примеров.

Как создать проект самостоятельно:

Создаем проект Maven

Добавляем в Maven зависимости:

Добавляем в проект код клиента:

Запускаем сначала Kafka если она не запущена, а затем сам клиент и получаем в конце примерно следующее:

Строчка, означающая успешное выполнение:

Что-то пошло нет так? Пишите в этот телеграмм канал — вместе разберемся.

Параметры Java Kafka producer example

Основных параметра Java Kafka Producer два:

  1. String server = «localhost:9092»; — адрес сервера Kafka. Предполагается, что настройки дефолтные. А значит, Kafka на локальной машине.
  2. String topicName = «test.topic»; — название топика куда пишет producer

Резюме

Это краткая статья, нацелена на проверку работы Java Kafka Producer Example. Минимум объяснений, архитектуры и настроек необходимых для работы из коробки. Хотите более подробную информацию по Kafka — Вам сюда.

Полный список статей по теме тут.

Заходите в наш телеграмм канал — Enterprise Stack Helper! Делитесь опытом или задавайте вопросы, если что-то непонятно.

Репозитории с примерам из статей по способам аутентификаци и авторизации https://github.com/BlockWit/kafka-security-examples.

 

Добавить комментарий