Add EventHub user properties in @metadata object (#66)

* Add EventHub user properties in @metadata object * Update VERSION * Update CHANGELOG.md
logstash-plugins · Jun 1, 2021 · dcb85da · dcb85da
1 parent 322e47a
commit dcb85da
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## 1.3.0
+ - Add EventHub `user properties` in `@metadata` object [#66](https://github.com/logstash-plugins/logstash-input-azure_event_hubs/pull/66)
+
 ## 1.2.3
  - Fixed missing configuration of `prefetch_count` and `receive_timeout` [#61](https://github.com/logstash-plugins/logstash-input-azure_event_hubs/pull/61)
 

diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.2.3
+1.3.0
diff --git a/lib/logstash/inputs/processor.rb b/lib/logstash/inputs/processor.rb
@@ -48,6 +48,7 @@ def onEvents(context, batch)
                 event.set("[@metadata][azure_event_hubs][sequence]", payload.getSystemProperties.getSequenceNumber)
                 event.set("[@metadata][azure_event_hubs][timestamp]",payload.getSystemProperties.getEnqueuedTime.getEpochSecond)
                 event.set("[@metadata][azure_event_hubs][event_size]", bytes.size)
+                event.set("[@metadata][azure_event_hubs][user_properties]", payload.getProperties)
               end
               @queue << event
               if @checkpoint_interval > 0