如何使用增量实时表在数据块中创建管道以从 kafka 读取数据

Question

1. 从卡夫卡读到这个有效

   raw_kafka_test = (spark.readStream .etc ) @dlt.table( table_properties={"pipelines.reset.allowed":"false"} ) def raw_kafka(): return raw_kafka_test

2. 从 delta 实时表读取无效 `@dlt.table( comment="Kakfa payload 的真实模式", 临时=真 ) def data_kafka(): 返回 （ dlt.read_stream("raw_kafka")

)`

我应该如何处理 delta live table 的读取