Apache Kafka

Clic destro nell’albero ▸ Aggiungi ▸ Richiesta Kafka.

Configurazione comune

Campo	Ruolo
URL	L’elenco dei broker, separati da virgole: hote1:9092,hote2:9092 — l’intera stringa viene risolta da Handlebars prima di essere suddivisa
Identificativo client	Il clientId annunciato ai broker
Topic	Il topic, qualunque sia la modalità
Modalità	produce, consume o browse

Autenticazione

Campo	Valori
Meccanismo SASL	none, plain, scram-sha-256, scram-sha-512
Utente SASL / Password SASL	La password accetta un valore di tipo Segreto
TLS	Attivabile in modo indipendente — un broker in TLS senza SASL funziona con il meccanismo none

Modalità produce

Chiave, valore, header del record e, facoltativamente, partizione. In assenza di una partizione esplicita si applica il partizionatore predefinito della libreria client. La risposta restituisce i metadati del record scritto: topic, partizione, offset.

Modalità consume

Campo	Ruolo
Gruppo	Il groupId del consumer
Offset di partenza	earliest, latest o specific
Offset specifico	Una stringa — gli offset Kafka sono interi a 64 bit
Partizioni	Un filtro lato client: l’assegnazione alle partizioni resta effettuata dal gruppo

Modalità browse

Ispeziona una partizione senza gruppo di consumer: Restorm ne preleva un numero limitato di messaggi e poi si disconnette. La partizione è obbligatoria in questa modalità.

È lo strumento giusto per guardare che cosa c’è in un topic senza creare un gruppo né spostare offset.

In uno scenario

• Produzione Kafka — azione singola, restituisce i metadati del record;
• Consumo Kafka — sottoscrive tramite il gruppo di consumer ed emette un evento per ogni messaggio;
• Chiusura connessione Kafka — interrompe il consumo.

Si veda Connessioni e flussi.

Snippet di codice

Cinque destinazioni: JavaScript (kafkajs, in produzione e in consumo) e kcat (produzione, consumo, ispezione senza gruppo).