search

logstash-plugins / logstash-input-kinesis

Logstash Plugin for AWS Kinesis Input
Apache License 2.0
45 stars 57 forks source link

Keep original metadata #64

Closed viradan closed 3 years ago

viradan commented 5 years ago

Any chance to keep original event-metadata as well? Smthg like

    metadata = build_metadata(record)
    @codec.decode(raw) do |event|
      @decorator.call(event)
add>>>      metadata_orig = event.get('@metadata')
add>>>      metadata = metadata.merge(metadata_orig)
      event.set('@metadata', metadata)