Следующий фрагмент кода демонстрирует создание нового производителя с помощью задания лишь обязательных параметров и использования значений по умолчанию для всего остального:
Properties kafkaProps = new Properties(); ❶
kafkaProps.put("bootstrap.servers", "broker1:9092,broker2:9092");
kafkaProps.put("key.serializer",
"org.apache.kafka.common.serialization.StringSerializer"); ❷
kafkaProps.put("value.serializer",
"org.apache.kafka.common.serialization.StringSerializer");
producer = new KafkaProducer<String, String>(kafkaProps); ❸
❶ Начинаем с объекта Properties.
❷ Поскольку мы планируем использовать строки для ключа и значения сообщения, воспользуемся встроенным типом StringSerializer.
❸ Создаем новый производитель, задавая подходящие типы ключа и значения и передавая в конструктор объект Properties.
При таком простом интерфейсе понятно, что управляют поведением производителя, в основном задавая соответствующие параметры конфигурации. В документации Apache Kafka описаны все параметры конфигурации (http://bit.ly/2sMu1c8). Кроме того, мы рассмотрим самые важные из них далее в этой главе.
Apache Kafka. Потоковая обработка и анализ данных
·
Тодд Палино
