Tengo una instancia presto que se ejecuta en un espacio de nombres y tiene un complemento personalizado y un detector de eventos configurado que obtiene todos los registros y los reenvía al puerto 24224.

Puedo ver los registros si están escritos como log.info ("cualquier cadena aquí") pero fluency.emit (etiqueta, mapa <>) no funciona en absoluto y no veo ningún registro u objeto de evento que se envíe a la instancia fluida .

¿Pueden ayudarme a configurar cómo puede funcionar o cómo puedo depurar esto cuando estoy en AWS EKS?

Cuando reviso los registros de daemonset fluentbit, puedo ver que está escuchando el puerto TCP 24224

 [input:forward:forward.0] listening on 0.0.0.0:24224

Aquí está la configuración de fluent-bit:

 fluent-bit.conf: |- [SERVICE] HTTP_Server On HTTP_Listen 0.0.0.0 HTTP_PORT 2020 Flush 10 Daemon Off Log_Level trace [INPUT] Name forward Port 24224 Listen 0.0.0.0 [Output] Name grafana-loki Match * Url <MY LOKI URL HERE> TenantID "" BatchWait 1 BatchSize 1048576 Labels {job="fluent-bit"} RemoveKeys kubernetes,stream AutoKubernetesLabels false LineFormat json LogLevel warn labelmap.json: |- { "kubernetes": { "container_name": "container", "host": "node", "labels": { "app": "app", "release": "release" }, "namespace_name": "namespace", "pod_name": "instance" }, "stream": "stream" }

Aquí está el contenido de mi archivo event-listener.properties de presto:

 event-listener.name=presto-fluent-logger event-listener.fluentd-host=127.0.0.1 event-listener.fluentd-port=24224 event-listener.fluentd-tag=presto.query

y he seguido todos los pasos de este enlace: https://github.com/komamitsu/fluency

Recibo un error en el complemento ConnectionException: conexión rechazada

Estoy seguro de que el complemento presto se ha registrado correctamente y el error muestra que no puede conectarse a mi instancia de fluentbit. No estoy seguro de qué host: puerto debo mantener en el complemento o en el archivo event-listener.properties

Pero no obtengo registros cuando ejecuto una consulta desde presto cli. Alguien puede ayudarme porfavor? No estoy muy seguro de qué todos los códigos necesito colocar aquí