Sends the contents of a FlowFile as a message to Apache Kafka
Tags: Apache, Kafka, Put, Send, Message, PubSub
Properties:
In the list below, the names of required properties appear in bold. Anyother properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language (or simply EL), and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.
| Name | Description | Default Value | Valid Values | EL | Sensitive |
|---|---|---|---|---|---|
| Known Brokers | A comma-separated list of known Kafka Brokers in the format <host>:<port> | No | No | ||
| Topic Name | The Kafka Topic of interest | Yes | No | ||
| Kafka Key | The Key to use for the Message | Yes | No | ||
| Delivery Guarantee | Specifies the requirement for guaranteeing that a message is sent to Kafka | 0 |
| No | No |
| Message Delimiter | Specifies the delimiter to use for splitting apart multiple messages within a single FlowFile. If not specified, the entire content of the FlowFile will be used as a single message. If specified, the contents of the FlowFile will be split on this delimiter and each section sent as a separate Kafka message. | Yes | No | ||
| Max Buffer Size | The maximum amount of data to buffer in memory before sending to Kafka | 1 MB | No | No | |
| Communications Timeout | The amount of time to wait for a response from Kafka before determining that there is a communications error | 30 secs | No | No | |
| Client Name | Client Name to use when communicating with Kafka | NiFi-null | No | No |
Relationships:
| Name | Description |
|---|---|
| failure | Any FlowFile that cannot be sent to Kafka will be routed to this Relationship |
| success | Any FlowFile that is successfully sent to Kafka will be routed to this Relationship |