Hi,We have a DLT pipeline with the following source code:import dlt
from pyspark.sql.functions import col, from_json
from pyspark.sql.types import LongType, StringType, StructField, StructType
KAFKA_TOPIC = "..."
BOOTSTRAP_SERVERS = "..."
# Define ...
