KafkaAdminClient的自定义事件处理

KafkaAdminClient 提供了一个基于回调的机制，允许开发者自定义事件处理程序。在初始化 KafkaAdminClient 实例时，可以通过传递一个 AdminClientConfig 对象来指定一个 AdminEventListener 的实例，该实例中定义了回调函数来处理 KafkaAdminClient 事件。

以下是一个示例代码，展示了如何自定义事件处理程序：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.AdminEventListener;
import org.apache.kafka.clients.admin.AdminEventType;
import org.apache.kafka.clients.admin.NewTopic;

import java.util.Collections;
import java.util.Properties;
import java.util.concurrent.ExecutionException;

public class CustomEventHandler {

    public static void main(String[] args) throws ExecutionException, InterruptedException {

        Properties properties = new Properties();
        properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

        // 创建 AdminClient 实例时指定 AdminEventListener
        AdminClient adminClient = AdminClient.create(properties, new MyAdminEventListener());

        // 创建新的主题
        NewTopic newTopic = new NewTopic("test", 1, (short) 1);
        adminClient.createTopics(Collections.singletonList(newTopic)).all().get();

        // 关闭 AdminClient 实例
        adminClient.close();
    }

    // 自定义 AdminEventListener
    private static class MyAdminEventListener implements AdminEventListener {

        @Override
        public void onAdminEvent(AdminEventType eventType, Object event) {
            System.out.println("Received event: " + eventType + ", " + event);
            // 自定义事件处理逻辑
        }
    }
}

在上面的示例代码中，通过创建一个 AdminClient 实例并指定一个自定义的 AdminEventListener 来处理 KafkaAdminClient 的事件。在 AdminEventListener 中，可以实现 onAdminEvent 回调函数来处理 KafkaAdminClient 不同类型的事件。用户可以自定义事件处理逻辑，例如记录日志，发送告警等。