[^---AIOKafkaConsumerThread]: Thread keepalive is not responding ERROR

[faust-streaming]

[^---AIOKafkaConsumerThread]: Thread keepalive is not responding ERROR

[paradonite-Y]

Did any one solved this problem or known how it happened?

I've also meet this problem in my project. The application raises these errors and do not restart itself. But it occurs randomly.

Furthermore, I cannot reproduce the problem.. The rocksdb is a key-value stores. How to delete older rows according to [Steps to reproduce]？

[informatica92]

Nope. I am still facing the same problem. I also tried to add some await asyncio.sleep(0) in the deletion procedure but the problem is still there.
I am now trying to set the entities I want to delete to None instead of deleting them.
I'll let you know if this solves the problem.

[informatica92]

I probably fond a solution.
In order to keep the discussion centralized in a single place, let me just send you the link of the issue where I have already posted the solution:
robinhood/faust#695 (comment)

[taybin]

We've had some fixes for tables and rocksdb in the meantime. I wonder if this is still an issue with the current master branch.

[wbarnha]

I think this has been fixed, I have never seen this bug occur since I've started maintaining this project. There are internal mechanisms in Faust to clean up old RocksDB entries.