How can I catch librdkafka errors to take action on them?

[theelderbeever]

We are receiving timeouts on our consumers due to long running processing which causes a consumer to leave the group. The problem is as far as the Rust code is concerned nothing has happened so we can't attempt a reconnect. How can we catch and take action on librdkafka errors?

[2024-09-17T16:26:27Z WARN librdkafka] librdkafka: MAXPOLL [thrd:main]: Application maximum poll interval (600000ms) exceeded by 234ms (adjust max.poll.interval.ms for long-running message processing): leaving group