Fix get topics https schema (#102)

shoothzj · Dec 6, 2022 · eba4afe · eba4afe
1 parent c1991b7
commit eba4afe
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/lib/api/pulsar/pulsar_partitioned_topic_api.dart b/lib/api/pulsar/pulsar_partitioned_topic_api.dart
@@ -87,9 +87,7 @@ class PulsarPartitionedTopicApi {
   static Future<List<TopicResp>> getTopics(
       int id, String host, int port, TlsContext tlsContext, String tenant, String namespace) async {
     try {
-      var url = tlsContext.enableTls
-          ? HttpUtil.https
-          : '${HttpUtil.http}$host:${port.toString()}/admin/v2/persistent/$tenant/$namespace/partitioned';
+      var url = '${tlsContext.getSchema()}$host:${port.toString()}/admin/v2/persistent/$tenant/$namespace/partitioned';
       var response = await HttpUtil.getClient(tlsContext, SERVER.PULSAR, id).get<String>(url);
       if (HttpUtil.abnormal(response.statusCode!)) {
         log('ErrorCode is ${response.statusCode}, body is ${response.data}');