Create a topic with 2 partitons

[amielc1]

using Confluent.Kafka; using Confluent.Kafka.Admin; using System; using System.Collections.Generic; using System.Threading.Tasks;

class Program { public static async Task Main(string[] args) { var config = new AdminClientConfig { BootstrapServers = "localhost:9092" };

    using (var adminClient = new AdminClientBuilder(config).Build())
    {
        try
        {
            var topicSpecifications = new List<TopicSpecification>
            {
                new TopicSpecification
                {
                    Name = "my-topic",
                    NumPartitions = 6,
                    ReplicationFactor = 1
                }
            };

            await adminClient.CreateTopicsAsync(topicSpecifications);

            Console.WriteLine("Topic created successfully");
        }
        catch (CreateTopicsException e)
        {
            Console.WriteLine($"An error occured creating topic: {e.Results[0].Error.Reason}");
        }
    }
}

}

[amielc1]

using Confluent.Kafka; using Confluent.Kafka.Admin; using System; using System.Threading.Tasks;

class Program { public static async Task Main(string[] args) { var config = new AdminClientConfig { BootstrapServers = "localhost:9092" };

    using (var adminClient = new AdminClientBuilder(config).Build())
    {
        try
        {
            await adminClient.CreatePartitionsAsync(new List<PartitionsSpecification>
            {
                new PartitionsSpecification
                {
                    Topic = "my-topic",
                    IncreaseTo = 10
                }
            });

            Console.WriteLine("Partitions increased successfully");
        }
        catch (CreatePartitionsException e)
        {
            Console.WriteLine($"An error occured increasing partitions: {e.Results[0].Error.Reason}");
        }
    }
}

}