Lightning
v2.13.5
Search documentation of Lightning
Settings
Lightning.KafkaTriggers.MessageHandling
(Lightning v2.13.5)
View Source
Contains the logic to persist a Kafka messages as a WorkOrder, Run and Dataclip.
Summary
Functions
convert_headers_for_serialisation(metadata)
persist_message(multi, trigger_id, message)
Functions
convert_headers_for_serialisation(metadata)
persist_message(multi, trigger_id, message)