diff --git a/app/services/events/create_batch_service.rb b/app/services/events/create_batch_service.rb
index 0ed0dbd7bb1..c2c806ce905 100644
--- a/app/services/events/create_batch_service.rb
+++ b/app/services/events/create_batch_service.rb
@@ -82,7 +82,8 @@ def produce_kafka_event(event)
           code: event.code,
           properties: event.properties,
           ingested_at: Time.zone.now.iso8601[...-1],
-          precise_total_amount_cents: event.precise_total_amount_cents.present? ? event.precise_total_amount_cents.to_s : "0.0"
+          precise_total_amount_cents: event.precise_total_amount_cents.present? ? event.precise_total_amount_cents.to_s : "0.0",
+          source: 'http_ruby'
         }.to_json
       )
     end
diff --git a/app/services/events/create_service.rb b/app/services/events/create_service.rb
index fe7d14fc4b8..988fbedff7a 100644
--- a/app/services/events/create_service.rb
+++ b/app/services/events/create_service.rb
@@ -73,7 +73,8 @@ def produce_kafka_event(event)
           # NOTE: Default value to 0.0 is required for clickhouse parsing
           precise_total_amount_cents: event.precise_total_amount_cents.present? ? event.precise_total_amount_cents.to_s : "0.0",
           properties: event.properties,
-          ingested_at: Time.zone.now.iso8601[...-1]
+          ingested_at: Time.zone.now.iso8601[...-1],
+          source: 'http_ruby'
         }.to_json
       )
     end