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

标签 c# .net apache-kafka

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

最佳答案

您可以使用 Confluent.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();
}

关于c# - 如何使用 C# 从 Kafka 获取主题列表,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30819179/

相关文章:

c# - 浮点值在 Int 中丢失

java - 如何解析来自Storm方案类中kafka主题的json数据?

java - Kafka Producer将消息发布到单个分区

c# - 寻找列表中元素的最佳位置

java - 多经纪人集群

c# - 仅显示文本文件 openfiledialog

C#迭代一个不断增长的多维数组

c# - 用不同的属性覆盖 GetHashCode

c# - 在服务器端获取 SSL 错误 SSL_ERROR_RX_RECORD_TOO_LONG

.Net WinForms TabControl 窃取关注表单激活