...

I can use some help here to determine the best implementation and improve the code in terms of resiliency and logging.

The proposal would be to include this functionality within Kafka's main functionality, so end-users do not need to bother with loading custom classes and leverage a vetted implementation instead.

Compatibility, Deprecation, and Migration Plan

...