Bytewax

- *Breaking change* Fixes issue with multi-worker recovery. If the
cluster crashed before all workers had completed their first epoch,
the cluster would resume from the incorrect position. This requires
a change to the recovery store. You cannot resume from recovery data
written with an older version.

- Dataflow continuation now works. If you run a dataflow over a finite
input, all state will be persisted via recovery so if you re-run the
same dataflow pointing at the same input, but with more data
appended at the end, it will correctly continue processing from the
previous end-of-stream.

- Fixes issue with multi-worker recovery. Previously resume data was
being routed to the wrong worker so state would be missing.

- *Breaking change* The above two changes require that the recovery
format has been changed for all recovery stores. You cannot resume
from recovery data written with an older version.

- Adds an introspection web server to dataflow workers.

- Adds `collect_window` operator.

- Added Google Colab support.

- Added tracing instrumentation and configurations for tracing backends.

- Fixes bug where window is never closed if recovery occurs after last
item but before window close.

- Recovery logging is reduced.

- *Breaking change* Recovery format has been changed for all recovery stores.
You cannot resume from recovery data written with an older version.

- Adds a `DynamoDB` and `Bigquery` output connector.

- Performance improvements.

- Support SASL and SSL for `bytewax.inputs.KafkaInputConfig`.