[KAFKA-15942] Implement ConsumerInterceptor

• Type: New Feature
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 3.8.0
• Component/s: clients, consumer
• Labels: consumer-threading-refactor interceptors
• Assignee: Lucas Brutschy
• Reporter: Philip Nee
• Created: 29/Nov/23 17:14
• Updated: 19/Feb/24 09:19
• Resolved: 30/Jan/24 08:08

Description

As title, we need to implement ConsumerInterceptor in the AsyncKafkaConsumer

 

This is the current code. The implementation would be very similar

if (interceptors != null)
    interceptors.onCommit(offsets); 

Issue Links

• links to: GitHub Pull Request #14963
• links to: GitHub Pull Request #15000