Supports Expression Language: true (will be evaluated using variable registry only)Topic Name | | | The name of the Kafka Topic to publish to. Supports Expression Language: true (will be evaluated using variable registry only) |
Record Writer | | Controller Service API: RecordSetWriterFactory Implementations: AvroRecordSetWriter ScriptedRecordSetWriter JsonRecordSetWriter ParquetRecordSetWriter RecordSetWriterLookup FreeFormTextRecordSetWriter XMLRecordSetWriter CSVRecordSetWriter | Specifies the Controller Service to use for writing out the records. |
Delivery Guarantee | 0 | - Best Effort
- Guarantee Single Node Delivery
- Guarantee Replicated Delivery
| Specifies the requirement for guaranteeing that a message is sent to Kafka. Corresponds to Kafka's 'acks' property. |
Message Header Encoding | UTF-8 | | For any attribute that is added as a message header, as configured via the <Attributes to Send as Headers> property, this property indicates the Character Encoding to use for serializing the headers. |
Security Protocol | PLAINTEXT | - PLAINTEXT
- SSL
- SASL_PLAINTEXT
- SASL_SSL
| Protocol used to communicate with brokers. Corresponds to Kafka's 'security.protocol' property. |
Kerberos Credentials Service | | Controller Service API: KerberosCredentialsService Implementation: KeytabCredentialsService | Specifies the Kerberos Credentials Controller Service that should be used for authenticating with Kerberos |
Kerberos Service Name | | | The service name that matches the primary name of the Kafka server configured in the broker JAAS file.This can be defined either in Kafka's JAAS config or in Kafka's config. Corresponds to Kafka's 'security.protocol' property.It is ignored unless one of the SASL options of the <Security Protocol> are selected. Supports Expression Language: true (will be evaluated using variable registry only) |
SSL Context Service | | Controller Service API: SSLContextService Implementations: StandardSSLContextService StandardRestrictedSSLContextService | Specifies the SSL Context Service to use for communicating with Kafka. |
Max Request Size | 1 MB | | The maximum size of a request in bytes. Corresponds to Kafka's 'max.request.size' property and defaults to 1 MB (1048576). |
Acknowledgment Wait Time | 5 secs | | After sending a message to Kafka, this indicates the amount of time that we are willing to wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the FlowFile will be routed to 'failure'. |
Max Metadata Wait Time | 5 sec | | The amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the entire 'send' call. Corresponds to Kafka's 'max.block.ms' property Supports Expression Language: true (will be evaluated using variable registry only) |
Compression Type | none | | This parameter allows you to specify the compression codec for all data generated by this producer. |
State management:
This component does not store state.Restricted:
This component is not restricted.System Resource Considerations:
None specified.