Hi, I just created a KIP-42 for adding producer and consumer interceptors for intercepting messages at different points on producer and consumer.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-42%3A+Add+Producer+and+Consumer+Interceptors Comments and suggestions are welcome! Thanks, Anna
