Client Apache Kafka per Mac

Inserisci host e porta di un broker; il resto del cluster viene scoperto tramite esso e Additional Bootstrap Servers elenca i broker da provare se il primo non risponde. Una connessione rappresenta un cluster, quindi non c’è un campo Database e la barra laterale mostra direttamente i topic.

Security Protocol è PLAINTEXT, SSL, SASL_PLAINTEXT o SASL_SSL e SASL Mechanism è PLAIN, SCRAM-SHA-256 o SCRAM-SHA-512. PLAIN è adatto a Confluent Cloud; SCRAM ad Amazon MSK e broker gestiti da te. Con SSL o SASL_SSL e nessuna modalità SSL scelta, vengono verificati catena del certificato e nome host. Una CA privata va in CA Certificate e un certificato e una chiave client aggiungono TLS reciproco.

Tramite un tunnel SSH, la connessione rimane sul broker di bootstrap, quindi legge solo le partizioni di cui è leader. Import from URL… accetta URL kafka://, che macOS non apre come link.

Aprire un topic mostra i messaggi più recenti, con il più nuovo alla fine, inclusi partizione, offset, timestamp, chiave, valore, intestazioni e dimensioni. I messaggi di partizioni diverse vengono intercalati per timestamp per facilitarne la lettura; sono partizione e offset a identificare un messaggio. Una chiave o un valore non UTF-8 appare in esadecimale e un tombstone rimane distinto da un messaggio vuoto.

KafkaQL sostituisce ordinamento e filtri con una posizione iniziale: CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET o FROM TIME con un timestamp ISO 8601, eventualmente limitato ad alcune partizioni. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER e DESCRIBE TOPIC coprono il resto del cluster.

DESCRIBE GROUP è il rapporto sul ritardo: offset confermato, offset finale e differenza, per partizione. Una partizione su cui il gruppo non ha mai confermato un offset non mostra ritardo, anziché un numero contato da zero, e SHOW GROUPS contrassegna l’elenco come troncato quando un broker non è raggiungibile.

PRODUCE INTO scrive un messaggio con chiave, intestazioni e partizione facoltative. Un messaggio con chiave ma senza partizione va dove lo collocherebbe il produttore di Kafka. I batch gzip, snappy, lz4 e zstd vengono decompressi durante la lettura, senza impostazioni da scegliere.

Le celle non possono essere modificate, le righe eliminate o le colonne ordinate perché Kafka non offre aggiornamenti, eliminazioni per messaggio o ordinamento sul server e la griglia disattiva quei controlli. Ogni pagina continua da dove si è fermata la precedente, quindi un topic che riceve nuovi messaggi non ne ripete né salta mai uno.

Eliminare un topic dalla barra laterale o con DROP TOPIC è l’unica azione distruttiva. Il cluster rimuove il log in seguito, quindi il topic può rimanere nell’elenco per un momento. Truncate non è disponibile: Kafka rimuove record per retention o tramite un offset per partizione e nessuno dei due svuota un topic.

L’importazione non è disponibile; inserisci messaggi in un topic con PRODUCE INTO. Esporta i messaggi letti da una query in CSV, JSON o XLSX.

L’app per iPhone e iPad non ha un driver Apache Kafka. Le connessioni Apache Kafka sincronizzate da un Mac compaiono nell’elenco, ma non si aprono.