在 Kafka 消费者中捕获登录并加入组事件

Question

我正在构建 Spring 应用程序以使用来自 kafka 的数据。它通过 @KafkaListener 方法成功获取消息，我可以通过添加

来接收一些事件

@EventListener
public void handleKafkaConsumerEvent(KafkaEvent event) {
   log.info("Kafka event " + event.toString())
}

但现在我想接收有关登录的事件（在日志文件中它就像“o.a.k.c.s.authenticator.AbstractLogin：成功登录。”记录）和（重新）加入对事件进行分组（在日志文件中类似于“o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=test_app] (Re-)joining group” ) 事件。

是否可以捕获该事件？

Answer 1

没有；这些日志条目是由 kafka-clients 直接创建的，与 Spring 无关，因此 Spring 无法为它们生成事件。

在 Kafka 消费者中捕获登录并加入组事件

Catch login and join group event in Kafka consumer

spring

kafka-consumer-api

spring-kafka