### Motivation Support user to add interceptors to producer and consumer.
### Modifications Add Consumer interceptors. ```java Message<T> beforeConsume(Message<T> message); void onAcknowledge(MessageId messageId, Throwable cause); void onAcknowledgeCumulative(MessageId messageId, Throwable cause); ``` Add Producer interceptors. ```java Message<T> beforeSend(Message<T> message); void onSendAcknowledgement(Message<T> message, MessageId msgId, Throwable cause); ``` ### Result Users can using interceptors in multiple scenarios, such as for applications to add custom logging or processing. [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2471 ] This message was relayed via gitbox.apache.org for [email protected]
