Balaji Rao
Balaji Rao
Using `timed_window` in Python 3.7.5 can sometimes lead to a coroutine being awaited more than once. Here's a sample program: ```python async def my_sink(x): print(x) await sleep(2) # raise Exception("Blah!")...
Use Wai with Warp.
What is the reason `RebalanceInProgressException` not considered retryable in the default `CommitRecovery` ? If we did so, this in combination with `StoredPendingCommit` introduced in https://github.com/fd4s/fs2-kafka/pull/117, should work well right? 🤔
Including `cats` and `async` in my project dependencies made this error go away. The dependencies for `cats` and `async` are in the dev profile for the muse project. Shouldn't they...