Configure a Kafka topic in C#

By default when you use the Confluent Kafka .NET client, a topic is created automatically for you when you publish your first message.

	// Create a producer that can be used to send messages to kafka that have no key and a value of type string
	using var producer = new ProducerBuilder<Null, string>(config)
	.Build();
	//Construct a message to send (generic type must match what was used above when creating the producer)
	var message = new Message<Null, string>
	{
	Value = value
	};
	await producer.ProduceAsync("kafka-topic-name", message) ;

view raw PublishMessageToKafka.cs hosted with ❤ by GitHub

However this will create a topic using the default settings. Typically you want to have more control when creating a topic. This is possible through the usage of the AdminClient:

	var config = new AdminClientConfig
	{
	BootstrapServers = "localhost:9092"
	};
	using var adminClient = new AdminClientBuilder(config)
	.Build()
	await adminClient.CreateTopicsAsync(new TopicSpecification[] {
	new TopicSpecification { Name = topicName, ReplicationFactor = 1, NumPartitions = 1 } });

view raw CreateTopic.cs hosted with ❤ by GitHub