Saltar al contenido

¿Usas TablePro a diario? Una licencia añade funciones de pago y financia la próxima versión. Comprar licenciaLicencia para apoyar TablePro

Cliente Apache Kafka para Mac

Lee un topic desde la posición que elijas, comprueba el retraso de cada grupo de consumidores y produce un mensaje de prueba con KafkaQL. Un topic es un registro: la cuadrícula lee mensajes y nunca los edita.

Funciona en MacEl controlador se descarga la primera vez que eliges Apache Kafka

Instrucción KafkaQL CONSUME sobre un tema orders, con mensajes listados por partición, offset, clave y marca de tiempo.

De un vistazo

Lenguaje de consulta
KafkaQL
Controlador
Se descarga en el primer uso
Conectar mediante
Host y puerto, Túnel SSH, SSL/TLS
Puerto predeterminado
9092
Versión mínima
0.11, documentada
iPhone y iPad
No se abre

Conectar

Introduce el host y puerto de un broker; a partir de él se descubre el resto del clúster. Servidores bootstrap adicionales enumera brokers que probar si el primero no responde. Una conexión corresponde a un clúster, así que no hay campo Base de datos y la barra lateral muestra sus topics directamente.

Protocolo de seguridad es PLAINTEXT, SSL, SASL_PLAINTEXT o SASL_SSL; Mecanismo SASL es PLAIN, SCRAM-SHA-256 o SCRAM-SHA-512. PLAIN sirve para Confluent Cloud; SCRAM, para Amazon MSK y brokers propios. Con SSL o SASL_SSL sin modo SSL elegido, se verifican la cadena de certificados y el host. Una CA privada va en Certificado CA; un certificado de cliente y clave añaden TLS mutuo.

Con un túnel SSH, la conexión permanece en el broker bootstrap, así que solo lee las particiones que este lidera. Importar desde URL… acepta URL kafka://, que macOS no abre como enlaces.

Lee, inspecciona y produce

Abrir un topic muestra sus mensajes más recientes, con el más nuevo al final, junto con partición, offset, fecha, clave, valor, cabeceras y tamaños. Los mensajes de distintas particiones se intercalan por fecha para facilitar la lectura; partición y offset identifican el mensaje. Claves o valores que no sean UTF-8 se muestran en hexadecimal; un tombstone sigue distinguiéndose de un mensaje vacío.

KafkaQL sustituye ordenación y filtros por una posición inicial: CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET o FROM TIME con fecha ISO 8601, opcionalmente limitada a algunas particiones. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER y DESCRIBE TOPIC cubren el resto del clúster.

DESCRIBE GROUP muestra el retraso: offset confirmado, offset final y diferencia por partición. Una partición en la que el grupo nunca confirmó un offset no muestra retraso, en lugar de contar desde cero; SHOW GROUPS marca la lista como truncada si un broker no es accesible.

PRODUCE INTO escribe un mensaje con clave, cabeceras y partición opcionales. Un mensaje con clave sin partición se coloca donde lo pondría el productor de Kafka. Los lotes gzip, snappy, lz4 y zstd se descomprimen al leerlos, sin elegir ningún ajuste.

No se pueden editar celdas, borrar filas ni ordenar columnas, porque Kafka no tiene actualización, eliminación por mensaje ni ordenación en el servidor; la cuadrícula atenúa esos controles. Cada página continúa donde terminó la anterior, por lo que un topic que recibe mensajes nunca repite ni omite ninguno.

Topics

Eliminar un topic desde la barra lateral o con DROP TOPIC es la única acción destructiva. El clúster borra el registro después, así que el topic puede permanecer un momento en la lista. No se ofrece Vaciar: Kafka elimina registros por retención o por offset en cada partición, y ninguno vacía un topic.

Transfiere datos

No hay importación; escribe mensajes en un topic con PRODUCE INTO. Exporta los mensajes leídos por una consulta como CSV, JSON o XLSX.

iPhone y iPad

La app para iPhone y iPad no tiene un controlador de Apache Kafka. Las conexiones de Apache Kafka sincronizadas desde un Mac aparecen en la lista, pero no se abren.

Limitaciones

  • No se lee Schema Registry, por lo que los valores Avro y Protobuf aparecen como bytes sin procesar.
  • No se admite crear temas, editar su configuración ni restablecer offsets de grupos de consumidores.
  • Los recuentos de mensajes son aproximados.

Preguntas sobre Apache Kafka

¿Por qué cargan los topics pero los mensajes agotan el tiempo?

El clúster anuncia direcciones inaccesibles desde este Mac, como un host de contenedor o IP privada. Corrige advertised.listeners o configura Direcciones de brokers para usar solo la dirección bootstrap.

¿Funciona la autenticación IAM de Amazon MSK?

No. Los mecanismos SASL disponibles son PLAIN, SCRAM-SHA-256 y SCRAM-SHA-512; crea un usuario SCRAM en el clúster MSK y conecta con SASL_SSL.

Consigue TablePro

La app para Mac se descarga y usa gratis. Un plan Starter o Equipo añade funciones opcionales.
Descargar para Mac

Requiere macOS 13 Ventura o posterior