用SpringAOP拦截kafka轮询请求

Question

我想拦截kafka轮询请求，以便记录一些信息，如响应时间，可用消息号。我使用springAOP没有任何成功。我已经使用@KafkaListener逐个消费消息，但我还想跟踪投票请求。以前有人做过这样的事吗?

Answer 1

您可能可以实现(通过扩展)DefaultKafkaConsumerFactory。在覆盖的createConsumer()方法中，您将super结果包装到上述AOP代理中，并通过MethodInterceptor拦截poll(Duration)调用。