使用 Spring AOP 拦截 kafka 轮询请求

【问题标题】：Intercept kafka poll request with SpringAOP使用 Spring AOP 拦截 kafka 轮询请求
【发布时间】：2021-01-21 15:00:57
【问题描述】：

我想拦截 kafka 轮询请求以记录一些信息，例如响应时间、可用消息号。我使用springAOP没有任何成功。我已经在使用@KafkaListener 来一一消费消息，但我也想跟踪投票请求。以前有人做过类似的事情吗？

【问题讨论】：

分享你已经尝试过的代码会给你具体的答案。

标签： spring-boot apache-kafka spring-kafka spring-aop

【解决方案1】：

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

【讨论】：