Inject hash and ephemeral_id into stats

Fixes #10885
This commit is contained in:
Mike Place 2019-06-24 13:08:42 +02:00 committed by Joao Duarte
parent 20fc465510
commit ed57c5dc53

View file

@ -152,6 +152,8 @@ module LogStash
# if extended_stats were provided, enrich the return value
if extended_stats
ret[:queue] = extended_stats["queue"] if extended_stats.include?("queue")
ret[:hash] = extended_stats["hash"]
ret[:ephemeral_id] = extended_stats["ephemeral_id"]
if opts[:vertices] && extended_stats.include?("vertices")
ret[:vertices] = extended_stats["vertices"].map { |vertex| decorate_vertex(vertex) }
end