View Source Lightning.KafkaTriggers.MessageHandling (Lightning v2.10.4)

Contains the logic to persist a Kafka messages as a WorkOrder, Run and Dataclip.

Summary

Functions

Link to this function

convert_headers_for_serialisation(metadata)

View Source
Link to this function

persist_message(multi, trigger_id, message)

View Source