有没有办法使用 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 获取观察者和离线副本计数?
回答我自己的有关使用 Confluence-Go 获取主题配置的问题。
可以使用adminClient方法DescribeConfigs来获取主题级别配置。
我仍然无法弄清楚如何列出观察者副本。也许我会提出一个单独的问题以更好地跟踪。