lib/logstash/inputs/processor.rb in logstash-input-azure_event_hubs-1.2.3 vs lib/logstash/inputs/processor.rb in logstash-input-azure_event_hubs-1.3.0

@@ -46,9 +46,10 @@
                 event.set("[@metadata][azure_event_hubs][partition]", context.getPartitionId)
                 event.set("[@metadata][azure_event_hubs][offset]", payload.getSystemProperties.getOffset)
                 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
                 now = Time.now.to_i
                 since_last_check_point = now - last_checkpoint