使用 Confluent 的 Apache Kafka .NET 客户端清除 Kafka 主题

Question

我使用 Confluent Kafka library for .NET 来发布和订阅 Kafka 主题。试图在他们的文档中找到是否可以用他们的 SDK 清除主题，但不能。所以问题是：是否可以从发布者 或 消费者中清除 Kafka 主题？

Answer 1

您需要 IAdminClient 个实例来删除主题。这是支持的方法的documentation。

示例使用 Confluent.Kafka v1.0.0:

using Confluent.Kafka;
using Confluent.Kafka.Admin;

...

using (var adminClient = new AdminClientBuilder(new AdminClientConfig { BootstrapServers = "localhost:9092" }).Build())
{
  try
  {
    adminClient.DeleteTopicsAsync(new string[] { "topic-to-delete" }).Wait();
  }
  catch (Exception e)
  {
    Console.WriteLine(e);
  }
}