Как передать массив словаря в приложение Faust?

Question

1. Как мы передаем массив словаря в приложение Faust?
2. Как мы можем получить временную метку события?

Я пробую Faust, но вроде как потерялся в том, как читать поток данных, который находится в массиве словарей.

Пример:

[{"product_id": "p1", "name": "pen"}, {"product_id": "p2", "name": "eraser"}]

class Products(faust.Record, coercions={UUID: UUID}):
    id: UUID
    product_id: str
    name: str

app = faust.App('prdapp', broker='kafka://localhost:9092')
prd_topic = app.topic('products', key_type=str, value_type=Order)

@app.agent(prd_topic)
async def process_product(prds):
    async for p in prds:
        print(f'product_id with uuid - {p.id}, ID is {p.product_id} and name is {p.name}')