Компоненты

Редактировал(а) Alexandr Fokin 2023/05/10 11:37
AdminClient

Помимо Consumer и Producer в данной библиотеке присутствует третий тип клиента - AdminClient.
Через данный клиент можно

  1. Получить данные о существующих topic их partitions.
  2. Получить список всех consumerGroup и подключенным к ним клиентам.
  3. Явно создать topic и partiton.
 1) Если topic с которым происходит взаимодействие не существует, то при обращении к нему из consumer или producer он будет автоматически создан.
2) Если consumer с указанной consumerGroup подключается к topic впервые, то для него запускается процесс оперделения смещения. По умолчанию для consumerGroup сгенерируются смещения в конце существующих partitions.
ConsumerClient 
ProducerClient 

 

Теги: