Kafka如何创建主题，并可选地指定分区数量和复制因子？

如何在Kafka中创建主题？可以在创建主题时指定分区数量和复制因子吗？如何通过命令行工具创建主题？如何通过Kafka API创建主题？

答：要在Kafka中创建主题，可以使用命令行工具或Kafka API。使用命令行工具创建主题，可以使用以下命令：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my-topic

在此命令中，使用--create参数指定创建主题的操作，--zookeeper参数指定Zookeeper地址，--replication-factor参数指定主题的副本个数，--partitions参数指定主题的分区数，--topic参数指定主题名称。例如上面的示例中创建了一个名为my-topic的主题，副本数为1，分区数为1。

使用Kafka API创建主题也很容易。以下是Java代码示例：

import kafka.admin.AdminUtils;
import kafka.utils.ZKStringSerializer$;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.exception.ZkNodeExistsException;

public class CreateTopicExample {

    public static void main(String[] args) {
        String topicName = "my-topic";
        int numPartitions = 1;
        int replicationFactor = 1;
        Properties topicConfig = new Properties();

        String zookeeperConnect = "localhost:2181";
        int sessionTimeoutMs = 10 * 1000;
        int connectionTimeoutMs = 8 * 1000;

        ZkClient zkClient = new ZkClient(
                zookeeperConnect,
                sessionTimeoutMs,
                connectionTimeoutMs,
                ZKStringSerializer$.MODULE$);

        try {
            AdminUtils.createTopic(
                    zkClient,
                    topicName,
                    numPartitions,
                    replicationFactor,
                    topicConfig);

        } catch (ZkNodeExistsException e) {
            System.out.println(e.getMessage());
        } finally {
            zkClient.close();
        }
    }
}

在此示例中，AdminUtils.createTopic()方法用于创建一个名为my-topic的主题，副本数为1，分区数为1。如果主题已存在，则会抛出ZkNodeExistsException异常。