Lightning
v2.15.16
Search documentation of Lightning
Default
Default
In-browser search
Settings
Lightning.KafkaTriggers.MessageHandling
(Lightning v2.15.16)
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)