[Question] Catching RequestTimedOutError, unable to in try catch #963

SwayGom · 2024-01-18T19:56:17Z

SwayGom
Jan 18, 2024

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

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

[Question] Catching RequestTimedOutError, unable to in try catch #963

Uh oh!

{{title}}

Uh oh!

Replies: 0 comments

Select a reply

Uh oh!

[Question] Catching RequestTimedOutError, unable to in try catch #963

Uh oh!

SwayGom Jan 18, 2024

Replies: 0 comments

SwayGom
Jan 18, 2024