Seyed Ali Osia

I have the same issue. I think its because of table updates where the producer tries to update change-log topic per message and its buffer gets full. Also I couldn't...

@deadpassive I found the solution and answer it [here](https://github.com/faust-streaming/faust/issues/497#issuecomment-1616396349).

I have the same question. How should I update table once per multiple events? updating per event will cause the producer buffer to get full.

@mcskatkat I have tested the following and I think it is working: ``` @app.agent(topic2) async def agent_b(stream): async for event in stream: # update table here @app.agent(topic1, sink=[topic2]) async def...