Cliente de Apache Kafka para Mac

Informe o host e a porta de um broker; o restante do cluster é descoberto por ele, e Additional Bootstrap Servers lista brokers para tentar quando o primeiro não responde. Uma conexão representa um cluster, portanto não há campo Database, e a barra lateral mostra os tópicos diretamente.

Security Protocol aceita PLAINTEXT, SSL, SASL_PLAINTEXT ou SASL_SSL, e SASL Mechanism aceita PLAIN, SCRAM-SHA-256 ou SCRAM-SHA-512. PLAIN atende ao Confluent Cloud; SCRAM ao Amazon MSK e a brokers hospedados por você. Com SSL ou SASL_SSL e sem um modo SSL escolhido, a cadeia do certificado e o nome do host são verificados. Uma CA privada fica em CA Certificate, e um certificado e uma chave de cliente adicionam TLS mútuo.

Por um túnel SSH, a conexão permanece no broker de bootstrap, portanto lê apenas as partições lideradas por ele. Import from URL… aceita URLs kafka://, que o macOS não abre como links.

Abrir um tópico mostra suas mensagens mais recentes, com a mais nova no fim, incluindo partição, offset, timestamp, chave, valor, cabeçalhos e tamanhos. Mensagens de partições diferentes são intercaladas por timestamp para facilitar a leitura; partição e offset identificam a mensagem. Uma chave ou valor que não é UTF-8 aparece em hexadecimal, e um tombstone permanece distinto de uma mensagem vazia.

KafkaQL substitui ordenação e filtros por uma posição inicial: CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET ou FROM TIME com um timestamp ISO 8601, opcionalmente limitado a algumas partições. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER e DESCRIBE TOPIC cobrem o restante do cluster.

DESCRIBE GROUP fornece o relatório de atraso: o offset confirmado, o offset final e a diferença, por partição. Uma partição em que o grupo nunca confirmou um offset não mostra atraso, em vez de um número contado do zero, e SHOW GROUPS marca a lista como truncada quando um broker não pode ser acessado.

PRODUCE INTO grava uma mensagem com chave, cabeçalhos e partição opcionais. Uma mensagem com chave e sem partição vai para onde o produtor do próprio Kafka a colocaria. Lotes gzip, snappy, lz4 e zstd são descomprimidos durante a leitura, sem configuração a escolher.

Células não podem ser editadas, linhas não podem ser excluídas e colunas não podem ser ordenadas, pois Kafka não tem atualização, exclusão por mensagem nem ordenação no servidor, e a grade desativa esses controles. Cada página continua de onde a anterior parou, portanto um tópico que recebe gravações nunca repete nem pula uma mensagem.

Excluir um tópico pela barra lateral ou com DROP TOPIC é a única ação destrutiva. O cluster remove o log depois, portanto o tópico pode permanecer na lista por um momento. Truncate não é oferecido: Kafka remove registros por retenção ou por um offset por partição, e nenhum desses métodos esvazia um tópico.

Não há importação; coloque mensagens em um tópico com PRODUCE INTO. Exporte as mensagens lidas por uma consulta como CSV, JSON ou XLSX.

O app para iPhone e iPad não tem um driver de Apache Kafka. As conexões Apache Kafka sincronizadas de um Mac aparecem na lista, mas não abrem.