如何使用 C# 从 Kafka 获取主题列表

2024-05-07

我想从卡夫卡获取主题列表。我正在使用 kafka-net 客户端,但无法在有关获取主题列表的文档中找到。


您可以使用 Confluence.Kafka 包中提供的 AdminClient 列出所有主题:

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

var adminConfig = new AdminClientConfig()
{
   BootstrapServers = "SERVER_URL"
};

using (var adminClient = new AdminClientBuilder(adminConfig).Build())
{
   var metadata = adminClient.GetMetadata(TimeSpan.FromSeconds(10));
   var topicsMetadata = metadata.Topics;
   var topicNames = metadata.Topics.Select(a => a.Topic).ToList();
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何使用 C# 从 Kafka 获取主题列表 的相关文章

随机推荐