使用SpringAOP截获kafka轮询请求

Question

我想截获kafka的投票请求，以便记录一些信息，如响应时间，可用消息数量。我使用了springAOP，但没有成功。我已经在使用@KafkaListener逐条消费消息，但我还想跟踪投票请求。以前有没有人做过这样的事情？

Answer 1

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