[Airflow] ImportError: cannot import name '_Union' from 'typing'

[iannamkr]

happened

low_offset, high_offset = consumer.get_watermark_offsets(partition)

impl.KafkaException: KafkaError{code=_UNKNOWN_PARTITION,val=-190,
str="Failed to get watermark offsets: Local: Unknown partition"}

solution

upgrade to v1.7.0

• Make broker_update() blocking to assure state is synchronized confluentinc/librdkafka#3287