0

Confluent.Kafka AdminClient 允许您创建一个主题,指定名称、分区数量、复制因子和保留(我猜其他设置通过 configs 属性)。然而,GetMetadata() 调用返回一个仅包含名称和分区信息的 TopicMetadata。有没有办法使用 .Net 客户端检索复制因子和保留时间?

 await adminClient.CreateTopicsAsync(new[]
                    {
                        new TopicSpecification
                        {
                            Name = topicName,
                            NumPartitions = _connectionSettings.TopicAutoCreatePartitionCount,
                            ReplicationFactor = _connectionSettings.TopicAutoCreatePartitionCount,
                            Configs = new Dictionary<string, string> {{"retention.ms", "9999999999999"}}
                        }
                    });
4

1 回答 1

1

要获得保留时间,您可以使用DescribeConfigsAsync

var results = await adminClient.DescribeConfigsAsync(new[] { new ConfigResource { Name = "topic_name", Type = ResourceType.Topic } });

foreach (var result in results)
{
    var retentionConfig = result.Entries.SingleOrDefault(e => e.Key == "retention.ms");
}

但我不确定获取复制因子的正确方法是什么,因为它不是用DescribedConfigsAsync. 我能想到的一种方法是使用GetMetadata,但这不是一个非常干净的解决方案:

var meta = adminClient.GetMetadata(TimeSpan.FromSeconds(5));
var topic = meta.Topics.SingleOrDefault(t => t.Topic == "topic_name");
var replicationFactor = topic.Partitions.First().Replicas.Length;
于 2020-08-19T08:04:24.313 回答