使用Camel-Kafka时，可以访问Kafka分区的数量吗？

import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.component.kafka.KafkaComponent;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.ListTopicsResult;
import org.apache.kafka.clients.admin.TopicListing;

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

public class KafkaPartitionCountExample {
    public static void main(String[] args) throws Exception {
        // 创建Camel上下文
        CamelContext context = new DefaultCamelContext();

        // 创建Kafka组件
        KafkaComponent kafka = new KafkaComponent();
        kafka.setBrokers("localhost:9092"); // 设置Kafka的地址
        context.addComponent("kafka", kafka);

        // 添加路由
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct:start")
                        .to("kafka:my-topic?brokers=localhost:9092&requestRequiredAcks=-1");

                from("direct:count")
                        .process(exchange -> {
                            // 创建Kafka AdminClient
                            Properties props = new Properties();
                            props.put("bootstrap.servers", "localhost:9092");
                            AdminClient adminClient = AdminClient.create(props);

                            // 获取Kafka分区的数量
                            ListTopicsResult topics = adminClient.listTopics();
                            for (TopicListing topic : topics.listings().get()) {
                                if (topic.name().equals("my-topic")) {
                                    System.out.println("Partition count: " + topic.partitions().size());
                                    break;
                                }
                            }

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

        // 启动Camel上下文
        context.start();

        // 发送消息到Kafka
        context.createProducerTemplate().sendBody("direct:start", "Hello, Kafka!");

        // 获取Kafka分区的数量
        context.createProducerTemplate().sendBody("direct:count", "");

        // 关闭Camel上下文
        context.stop();
    }
}