[Question] Catching RequestTimedOutError, unable to in try catch

[Jgomez13]

Hey,

so I'm testing request timeout errors with Microsoft EventHubs with aiokafka but am not seeing any way to catch these errors from the aiokafka client, the only errors im getting printed are :

Got error produce response: [Error 7] RequestTimedOutError

Im doing something like this

try:
    for topic in self.topics:
        print(f'{self.client_id} SENDING topic: {topic} partition: {partition}')
        resp = await self.producer.send_and_wait( topic, partition=partition,value=msg)
        print(f'{self.client_id} SENT:) topic:{topic}, p:{resp.partition} o:{resp.offset} ts:{resp.timestamp} readable_ts:{datetime.utcfromtimestamp((resp.timestamp/1000))} ts_type:{resp.timestamp_type} log_st_o:{resp.log_start_offset}')
        self.totalSent += 1
        #print(f'{self.client_id} sent {self.totalSent} messages')
except KafkaTimeoutError as e:
    print( 'KafkaTimeoutError in send', e)
except RequestTimedOutError as e:
    print( 'RequestTimedOutError in send', e)
except Exception as e:
    print( 'Exception in send', e)

with output such as:
01/18/2024 19:40:47-ProducerAio01510: Producer: pyaio-myproducer SENDING topic: aio-testtopic partition: 0

Got error produce response: [Error 7] RequestTimedOutError