Очистить тему кафки программно с помощью C #

Question

Мне нужно очистить или удалить темы Kafka программно, используя язык C #.В настоящее время я использовал библиотеку Confluent.Kafka для публикации и использования тем Kafka.

Я могу удалять темы Kafka с помощью командной строки, например, такой:

kafka-topics.bat --zookeeper 192.108.94.79:2181 --delete --topic test-topic3

Доступна ли какая-либо библиотека или способ для очистки темы Kafka программно с использованием языка C #?

Answer 1

Мы можем быстро удалить темы Kafka, используя Confluent.Kafka библиотека версии 1.0.0.Но в настоящее время он находится в бета-версии.Эта библиотека поддерживает утилиты администратора Kafka.Следующий код помогает очистить / удалить темы Kafka.

using Confluent.Kafka;
using System;
using System.Collections.Generic;

namespace deleteKafkaTopic
{
    public class Program
    {
        public static void Main(string[] args)
        {
            Console.WriteLine($"librdkafka Version: {Library.VersionString} ({Library.Version:X})");
            Console.WriteLine($"Debug Contexts: {string.Join(", ", Library.DebugContexts)}");

            IEnumerable<string> topicList = new List<string>() { "test-topic4" };
            deleteTopics("192.168.64.49:9092", topicList);
        }
        static void deleteTopics(string brokerList, IEnumerable<string> topicNameList)
        {
            using (var adminClient = new AdminClient(new AdminClientConfig { BootstrapServers = brokerList }))
            {
                adminClient.DeleteTopicsAsync(topicNameList, null);
            }
        }
    }
}