Class KafkaReaderProcessorDescriptorModel

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

Inheritance

ProcessorDescriptorModel

KafkaReaderProcessorDescriptorModel

Namespace: Trivium.Eventflow.Model

Assembly: Trivium.Eventflow.Model.dll

Syntax

public sealed class KafkaReaderProcessorDescriptorModel : ProcessorDescriptorModel

Properties

int	ConnectionId Идентификатор объекта соединения с Кафкой.
string	ConsumerGroupId Идентификатор группы потребителей.
ConsumerGroupIdSuffixType	ConsumerGroupIdSuffix Суффикс идентификатора группы потребителей.
bool?	EnableAutoCommit Значение для автоматического коммита.
int?	ProcessTimeoutInSeconds Таймаут на обработку сообщения.
string	Topic Имя топика.