Kafka3ConnectionService¶
Beschreibung¶
Bietet und verwaltet Verbindungen zu Kafka Brokern für Produzenten- oder Verbraucheroperationen.
Eigenschaften¶
In der folgenden Liste sind die erforderlichen Eigenschaften mit einem Sternchen (*) gekennzeichnet. Andere Eigenschaften werden als optional betrachtet. Die Tabelle zeigt auch alle Standardwerte und ob eine Eigenschaft die NiFi Expression Language unterstützt.
Display Name (Anzeigename) |
API-Name |
Standardwert |
Zugelassene Werte |
Beschreibung |
|---|---|---|---|---|
SSL Context Service |
SSL Context Service |
Dienst zur Unterstützung der SSL-Kommunikation mit Kafka-Brokern |
||
Acknowledgment Wait Time * |
ack.wait.time |
5 sec |
Nach dem Senden einer Meldung an Kafka gibt dies den Zeitraum an, den der Dienst auf eine Antwort von Kafka wartet. Wenn Kafka die Meldung innerhalb dieses Zeitraums nicht bestätigt, löst der Dienst eine Ausnahme aus. |
|
Bootstrap Servers * |
bootstrap.servers |
Eine durch Kommas getrennte Liste von Kafka Bootstrap-Servern im Format host:port. Entspricht der Kafka-Eigenschaft „bootstrap.servers“ |
||
Client Timeout * |
default.api.timeout.ms |
60 sec |
Standard-Timeout für Kafka-Client-Operationen. Entspricht dem Kafka-Eigenschaft „default.api.timeout.ms.“ Die Kafka-Eigenschaft „request.timeout.ms“ wird aus der Hälfte des konfigurierten Timeouts abgeleitet |
|
Transaction Isolation Level * |
isolation.level |
read_committed |
|
Legt fest, wie der Dienst mit Transaktionsisolationstufen bei der Kommunikation mit Kafka umgeht. Mit der Einstellung „uncommitted“ werden Meldungen sofort empfangen, sobald sie in Kafka geschrieben wurden – auch wenn die zugehörige Transaktion später vom Produzenten zurückgezogen wird. Die Einstellung „committed“ sorgt dafür, dass nur solche Meldungen empfangen werden, deren Transaktionen tatsächlich abgeschlossen wurden. Dadurch kann es jedoch zu Verzögerungen kommen, da der Verbraucher auf das vollständige Abschließen der Transaktion warten muss. Diese Einstellung entspricht der Kafka-Eigenschaft „isolation.level“. |
Max Metadata Wait Time * |
max.block.ms |
5 sec |
Der Zeitspanne, die der Herausgeber beim Aufruf von „send“ maximal wartet, um Metadaten zu erhalten oder den Puffer zu leeren, „send“-Aufruf fehlschlägt. Entspricht der Kafka-Eigenschaft „max.block.ms“ |
|
Max Poll Records * |
max.poll.records |
10000 |
Die maximale Anzahl an Datensätzen, die Kafka bei einem einzelnen Abruf zurückliefern soll. |
|
SASL Mechanism * |
sasl.mechanism |
GSSAPI |
|
SASL-Mechanismus, der für die Authentifizierung verwendet wird. Entspricht der Eigenschaft „sasl.mechanism“ des Kafka-Clients |
SASL Password * |
sasl.password |
Das Kennwort wird zusammen mit dem konfigurierten Benutzernamen bereitgestellt, wenn die PLAIN- oder SCRAM SASL-Mechanismen verwendet werden. |
||
SASL Username * |
sasl.username |
Benutzername mit konfiguriertem Kennwort bei Verwendung von PLAIN- oder SCRAM SASL-Mechanismen |
||
Security Protocol * |
security.protocol |
PLAINTEXT |
|
Sicherheitsprotokoll, das für die Kommunikation mit Brokern verwendet wird. Entspricht der Eigenschaft „security.protocol“ des Kafka-Clients |
Statusmanagement¶
Diese Komponente speichert keinen Status.
Eingeschränkt¶
Diese Komponente ist nicht eingeschränkt.
Hinweise zu Systemressourcen¶
Diese Komponente enthält keine Angaben zu den Systemressourcen.