We have EFK stack running in out k8s cluster. All components are part of cluster. Now we want to implement logstash to create parsing rules for logs. How do I install it in current environment? What should I use for input section since we are using fluent-bit as log collector. I seen many blogs using beats optoin for filebeat, do i need to use anyhing else other than beats for fluentbit agent. Can I add parsing rules using grok plugin to fulentbit configmap file?
port => 5044