KafkaRecordSink_2_6
Описание
Предоставляет сервис для записи записей в тему Kafka 2.6+.
Теги
kafka, record, sink
Свойства
| Название | Описание |
|---|---|
| Kafka Brokers | Comma-separated list of Kafka Brokers in the format host:port Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Topic Name | Название темы Kafka для публикации. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Record Writer | Specifies the Controller Service to use for writing out the records. |
| Delivery Guarantee | Указывает требование для гарантии отправки сообщения в Kafka. Соответствует свойству Kafka 'acks'. |
| Message Header Encoding | Для любого атрибута, который добавляется в качестве заголовка сообщения и настраивается с помощью свойства <Атрибуты для отправки в качестве заголовков>, это свойство указывает кодировку символов, используемую для сериализации заголовков. |
| Security Protocol | Security protocol used to communicate with brokers. Corresponds to Kafka Client security.protocol property |
| Kerberos User Service | Service supporting user authentication with Kerberos |
| Kerberos Service Name | The service name that matches the primary name of the Kafka server configured in the broker JAAS configuration Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| SSL Context Service | Service supporting SSL communication with Kafka brokers |
| Max Request Size | Максимальный размер запроса в байтах. Соответствует свойству Kafka «max.request.size» и по умолчанию равно 1 МБ (1048576). |
| Acknowledgment Wait Time | После отправки сообщения в Kafka это значение указ ывает, сколько времени мы готовы ждать ответа от Kafka. Если Kafka не подтвердит получение сообщения в течение этого времени, FlowFile будет перенаправлен в состояние «сбой». |
| Max Metadata Wait Time | Время, в течение которого издатель будет ожидать получения метаданных или очистки буфера во время вызова 'send' перед завершением всего вызова 'send'. Соответствует свойству Kafka 'max.block.ms' Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Compression Type | Этот параметр позволяет указать кодек сжатия для всех данных, генерируемых этим производителем. |