Kafka: 新API kafka.utils.ZkUtils在从0.8升级到2.1中的变化

要解决“Kafka: 新API kafka.utils.ZkUtils在从0.8升级到2.1中的变化”问题，您可以按照以下步骤进行操作：

1. 首先，了解从Kafka 0.8到2.1的重大变化。这些变化包括API的更新和旧API的弃用。您可以参考Kafka官方文档或升级指南，以了解这些变化的详细信息。

2. 在应用程序中查找使用kafka.utils.ZkUtils的代码。这些代码通常用于与ZooKeeper进行交互，例如创建主题、查找分区等。

3. 对于每个使用kafka.utils.ZkUtils的代码块，根据新版本的Kafka API进行更新。这包括使用新的API类和方法，以及更改现有代码以与新API兼容。

4. 以下是一个示例代码，演示如何从0.8版本升级到2.1版本的变化：

import kafka.admin.AdminUtils;
import kafka.utils.ZKStringSerializer$;
import org.I0Itec.zkclient.ZkClient;
import scala.collection.JavaConversions;

public class ZkUtilsExample {
    private static final String ZK_CONNECT = "localhost:2181";
    private static final int SESSION_TIMEOUT = 10000;
    private static final int CONNECTION_TIMEOUT = 10000;

    public static void main(String[] args) {
        // 创建ZkClient实例
        ZkClient zkClient = new ZkClient(ZK_CONNECT, SESSION_TIMEOUT, CONNECTION_TIMEOUT, ZKStringSerializer$.MODULE$);

        // 创建主题
        String topic = "test-topic";
        int partitions = 4;
        int replication = 1;
        Properties topicConfig = new Properties();
        AdminUtils.createTopic(zkClient, topic, partitions, replication, topicConfig);

        // 获取主题的分区列表
        scala.collection.Seq<String> topicPartitions = AdminUtils.fetchTopicPartitions(zkClient, topic);
        List<String> partitionList = JavaConversions.seqAsJavaList(topicPartitions);
        System.out.println("Partitions for topic " + topic + ": " + partitionList);

        // 关闭ZkClient连接
        zkClient.close();
    }
}

请注意，上述示例代码仅涵盖了创建主题和获取主题分区列表的一部分。根据您的实际需求，您可能需要进一步修改代码以适应新的Kafka API。

希望上述解决方法对您有所帮助！