Worked on enhancing the reliability of the persister component in the m1a2st/kafka repository by refining its asynchronous processing and error management. Addressed a key bug by replacing future.get() with future.join(), which improved error propagation and reduced the risk of indefinite blocking during high-load scenarios. Introduced explicit timeout controls to align with KAFKA-17991, ensuring that asynchronous operations would not stall processing. Focused on clarifying execution paths and improving observability for better maintainability. Utilized Java and concurrency techniques, supported by unit testing, to deliver more robust and predictable behavior in the persister’s handling of asynchronous tasks and error conditions.