Class KafkaWriterProcessorDescriptorModel

Модель описания процессора записи сообщений в Кафку.

Inheritance

ProcessorDescriptorModel

KafkaWriterProcessorDescriptorModel

Namespace: Trivium.Eventflow.Model

Assembly: Trivium.Eventflow.Model.dll

Syntax

public sealed class KafkaWriterProcessorDescriptorModel : ProcessorDescriptorModel

Properties

int	ConnectionId Идентификатор объекта соединения с Кафкой.
int?	DelayWriteUndeliveredMessagesMs Задержка записи неотправленных сообщений в миллисекундах. Время необходимое для накопления неотправленных сообщений и разгрузки локальной очереди.
MessageSourceDefinitionModel	PropertyToWrite Наименование свойства, записываемого в Кафку. Если null - записываются все свойства.
string	Topic Топик в Кафке, в который требуется писать сообщения.