使用 Spring AOP 拦截 kafka poll 请求

Question

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

Answer 1

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