Thank you for the reply! do you have a code example? I was able to do it for a delta table through a notebook in a serverless cluster using kafka, but cannot do it for a streaming table nor in a dlt pipeline