apache-flink-statefun>=3.3.0
kafka-python
protobuf
