Kafka3ConnectionService¶
Description¶
Provides and manages connections to Kafka Brokers for producer or consumer operations.
Tags¶
kafka, openflow
Properties¶
In the list below required Properties are shown with an asterisk (*). Other properties are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|---|---|---|---|
| SSL Context Service | SSL Context Service | Service supporting SSL communication with Kafka brokers | ||
| Acknowledgment Wait Time * | ack.wait.time | 5 sec | After sending a message to Kafka, this indicates the amount of time that the service will wait for a response from Kafka.If Kafka does not acknowledge the message within this time period, the service will throw an exception. | |
| Bootstrap Servers * | bootstrap.servers | Comma-separated list of Kafka Bootstrap Servers in the format host:port. Corresponds to Kafka bootstrap.servers property | ||
| Client Timeout * | default.api.timeout.ms | 60 sec | Default timeout for Kafka client operations. Mapped to Kafka default.api.timeout.ms. The Kafka request.timeout.ms property is derived from half of the configured timeout | |
| Transaction Isolation Level * | isolation.level | read_committed |
| Specifies how the service should handle transaction isolation levels when communicating with Kafka.The uncommited option means that messages will be received as soon as they are written to Kafka but will be pulled, even if the producer cancels the transactions.The committed option configures the service to not receive any messages for which the producer’s transaction was canceled, but this can result in some latency since theconsumer must wait for the producer to finish its entire transaction instead of pulling as the messages become available.Corresponds to Kafka isolation.level property. |
| Max Metadata Wait Time * | max.block.ms | 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 theentire ‘send’ call. Corresponds to Kafka max.block.ms property | |
| Max Poll Records * | max.poll.records | 10000 | Maximum number of records Kafka should return in a single poll. | |
| SASL Mechanism * | sasl.mechanism | GSSAPI |
| SASL mechanism used for authentication. Corresponds to Kafka Client sasl.mechanism property |
| SASL Password * | sasl.password | Password provided with configured username when using PLAIN or SCRAM SASL Mechanisms | ||
| SASL Username * | sasl.username | Username provided with configured password when using PLAIN or SCRAM SASL Mechanisms | ||
| Security Protocol * | security.protocol | PLAINTEXT |
| Security protocol used to communicate with brokers. Corresponds to Kafka Client security.protocol property |
State management¶
This component does not store state.
Restricted¶
This component is not restricted.
System Resource Considerations¶
This component does not specify system resource considerations.