Блок-источник данных, получаемых из топика Apache Kafka.
Тип брокера: Apache Kafka
Входящий тип данных: НЕТ
Исходящий тип данных: DaJet.Flow.Payload
Возможна трансформация исходящего типа данных в тип данных System.Data.IDataRecord
при помощи блока-трансформатора DaJet.Flow.PayloadToRecordTransformer.
Настройки блока Consumer (подробнее в документации Confluent):
| Опция | Значение | Пример |
|---|---|---|
| Topic | Идентификатор топика на сервере Kafka для чтения данных | dajet-topic |
| ClientId | Идентификатор клиента для логирования на сервере Kafka | dajet-app-1 |
| GroupId | Индентификатор пользовательской группы на сервере Kafka | dajet-group |
| BootstrapServers | Адрес подключения к кластеру Kafka (обязательно) | 127.0.0.1:9092 |
| AutoOffsetReset | Стратегия определения оффсета для клиента, если его нет | earliest |
| EnableAutoCommit | Автоматическое фоновое подтверждение клиентского оффсета | false |
| SessionTimeoutMs | Таймаут для определения сервером того, что клиент "живой" | 60000 |
| HeartbeatIntervalMs | Периодичность отправки сигнала "живой" координатору клиентов | 20000 |