Hi - I’m implementing a logs receiver, and wish to call
consumer.ConsumeLogs(ctx context.Context, ld pdata.Logs) error.
I have a struct representing log records, and wish to convert this to
pdata.Logs. However, I’m not finding a way to do this that doesn’t require direct interaction with internal packages.
Am I right to think this should be possible? Is there an expected approach to this that someone could point me to?
kafkaexporterto output logs. Should not be very difficult. The primary question will be in what format you write to kafka.
kafkaexportercurrently supports a couple serialization formats for traces (otlp, jaeger). We will need to decide what to support for logs.
Fluent bit->OpenTelemetry Collector->any output of choicepipeline and found that it's actually plausible with the recent additions to the collector and a (rather small) modification to a FluentBit Helm chart. I have prepared a doc that summarises it and brings rationale behind some newly added issues (mostly related to K8s Processor extensions): https://docs.google.com/document/d/1QlFbXz0eQUaKXK1WrnEs3VqRkcPD2RAdXJdJMjnOSd8/edit?usp=sharing Would love to hear if that ideas sounds reasonable and if so, will be happy to work on that. I could also demo that during the upcoming SIG meeting and discuss it