如何在testcontainers kafka镜像中执行kafka-configs命令

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.Config;
import org.apache.kafka.clients.admin.DescribeConfigsResult;
import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.admin.AlterConfigsResult;
import org.apache.kafka.clients.admin.ConfigEntry;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.utility.DockerImageName;

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

public class KafkaConfigsExample {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 创建Kafka容器
        KafkaContainer kafkaContainer = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:6.2.0"));

        // 启动Kafka容器
        kafkaContainer.start();

        // 等待Kafka容器完全启动
        kafkaContainer.waitForContainerReady();

        // 获取Kafka容器的地址和端口
        String bootstrapServers = kafkaContainer.getBootstrapServers();

        // 创建Kafka客户端配置
        Properties properties = new Properties();
        properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

        // 创建AdminClient对象
        AdminClient adminClient = AdminClient.create(properties);

        // 执行kafka-configs命令，查看配置信息
        DescribeConfigsResult describeConfigsResult = adminClient.describeConfigs(Collections.singleton("topic-name"));
        Config config = describeConfigsResult.all().get().get("topic-name");
        System.out.println("Topic Configs: " + config.entries());

        // 执行kafka-configs命令，修改配置
        ConfigEntry configEntry = new ConfigEntry("cleanup.policy", "compact");
        AlterConfigsResult alterConfigsResult = adminClient.alterConfigs(Collections.singletonMap("topic-name", Collections.singleton(configEntry)));
        alterConfigsResult.all().get();

        // 关闭AdminClient对象
        adminClient.close();

        // 关闭Kafka容器
        kafkaContainer.stop();
    }
}