confluence-go:如何使用管理客户端获取主题配置?

问题描述 投票:0回答:1

有没有办法使用 Confluence-go Admin API 获取所有主题配置,如retention.ms、min.isr等? 即生成类似于下面的输出,当我使用 confluence java 工具 kafka-topics 时得到的输出


[appuser@kafka1 ~]$ kafka-topics --bootstrap-server localhost:9092 --describe --topic test-topic
Topic: test-topic       TopicId: lZ-UAHvXSRiKV_dLLXaauw PartitionCount: 1       ReplicationFactor: 3    Configs: confluent.placement.constraints={"version":1,"replicas":[{"count":2,"constraints":{"rack":"site1"}}],"observers":[{"count":1,"constraints":{"rack":"site2"}}]},retention.ms=172800000
        Topic: test-topic       Partition: 0    Leader: 1       Replicas: 1,2,3 Isr: 1,2        Offline:        Observers: 3

我尝试使用 Confluence Go API,但在返回的元数据中找不到任何内容来列出主题的所有配置

有没有办法使用管理 API 获取观察者和离线副本计数?

librdkafka confluent-kafka-go
1个回答
0
投票

回答我自己的有关使用 Confluence-Go 获取主题配置的问题。

可以使用adminClient方法DescribeConfigs来获取主题级别配置。

我仍然无法弄清楚如何列出观察者副本。也许我会提出一个单独的问题以更好地跟踪。

© www.soinside.com 2019 - 2024. All rights reserved.