Apache Kafka

Clic derecho en el árbol ▸ Añadir ▸ Petición Kafka.

Configuración común

Campo	Función
URL	La lista de brokers, separados por comas: hote1:9092,hote2:9092 — la cadena completa se resuelve con Handlebars antes de dividirse
Identificador de cliente	El clientId anunciado a los brokers
Tema	El tema, sea cual sea el modo
Modo	produce, consume o browse

Autenticación

Campo	Valores
Mecanismo SASL	none, plain, scram-sha-256, scram-sha-512
Usuario SASL / Contraseña SASL	La contraseña acepta un valor de tipo Secreto
TLS	Se puede activar de forma independiente: un broker en TLS sin SASL funciona con el mecanismo none

Modo produce

Clave, valor, cabeceras de registro y, opcionalmente, partición. Sin partición explícita se aplica el particionador por defecto de la biblioteca cliente. La respuesta devuelve los metadatos del registro escrito: tema, partición, offset.

Modo consume

Campo	Función
Grupo	El groupId del consumidor
Offset inicial	earliest, latest o specific
Offset específico	Una cadena: los offsets de Kafka son enteros de 64 bits
Particiones	Un filtro del lado del cliente: la asignación a las particiones sigue haciéndola el grupo

Modo browse

Inspecciona una partición sin grupo de consumidores: Restorm toma de ella un número limitado de mensajes y después se desconecta. La partición es obligatoria en este modo.

Es la herramienta adecuada para mirar qué hay en un tema sin crear un grupo ni mover ningún offset.

En un escenario

• Producción Kafka — acción unitaria, devuelve los metadatos del registro;
• Consumo Kafka — se suscribe mediante el grupo de consumidores y emite un evento por mensaje;
• Cierre de conexión Kafka — detiene el consumo.

Consulte Conexiones y flujos.

Fragmentos de código

Cinco destinos: JavaScript (kafkajs, en producción y en consumo) y kcat (producción, consumo, inspección sin grupo).