Quang Vũ
Results
2
comments of
Quang Vũ
Here are my example code: > app = faust.App( > os.getenv('appname'), > broker=os.getenv('broker'), > broker_commit_livelock_soft_timeout=os.getenv('livelock'), > stream_wait_empty=False > ) > > topic_last=app.topic(os.getenv('topic_name')) > > @app.agent(topic_last) > async def Last_Topic(requests): >...
> I ran into the same issue. As a workaround, I had to create /kafka-manager/mutex/locks and /kafka-manager/mutex/leases nodes manually. After that, I am able to add clusters. Can you explain...