Sou novo no Fluent and Fluent Bit.
Bit Fluente (0.13) ouve tcp e encaminha para uma instância Fluente (td-agent 3.2). Fluente vai empurrá-lo para coelhinho. O processo básico está funcionando.
Bit Fluente gera mensagens como
2018-07-09T11:44:48+02:00 tcp.0
{"msg":["dev.fluent",1531129488,{"test":"woooooooo 2018-07-09 11:44:48"}]}
a tag encaminhada é tcp.0. A Fluent espera um formato como o seguinte, infelizmente.
2018-07-10T10:15:13+02:00 dev.fluent {"birds":"are blue 2018-07-10 10:15:13"}
O roteamento rabbitmq (tag = routing_key sem qualquer outra configuração) funcionaria corretamente com essa formatação "antiga".
Não encontrei nenhuma solução para reescrever a tag de mensagem com parsers / filters. Alguém tem uma ideia para fazer o roteamento?
Felicidades Chris
Tags fluentd