Leo Singer

### Bug Description When my dataflow contains a windowing operation that uses event time, I cannot collect any OpenTelemetry traces. The dataflow repeatedly prints the following error message: ``` OpenTelemetry...

There is a known issue in confluent-kafka-python that the admin client does not automatically start calling any configured oauth_cb callbacks. The workaround is to call `poll()` once before calling `list_topics()`....