diff options
| author | luwenpeng <[email protected]> | 2020-03-09 16:56:39 +0800 |
|---|---|---|
| committer | luwenpeng <[email protected]> | 2020-04-01 13:43:57 +0800 |
| commit | b18cc3928cbf20eee0859ab59fdd788074850520 (patch) | |
| tree | d93c9c427452e4edc1acf4f6b9a11a9e6bbfa234 | |
| parent | 8079c4142f1eb457d499b838589eecfec5aff891 (diff) | |
TSG-935 当 disable kafka log 时，不再解析 broker_list
| -rw-r--r-- | platform/src/ssl_fetch_cert.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/platform/src/ssl_fetch_cert.cpp b/platform/src/ssl_fetch_cert.cpp index 9dadcf6..dc9ddd7 100644 --- a/platform/src/ssl_fetch_cert.cpp +++ b/platform/src/ssl_fetch_cert.cpp @@ -38,11 +38,14 @@ int ssl_mid_cert_kafka_logger_create(const char *profile, const char *section) MESA_load_profile_int_def(profile, section, "mc_cache_enable", &enable, 0); MESA_load_profile_string_def(profile, section, "mc_cache_eth", nic_name, sizeof(nic_name), "eth0"); MESA_load_profile_string_def(profile, section, "mc_cache_topic", topic_name, sizeof(topic_name), "PXY-EXCH-INTERMEDIA-CERT"); + if (!enable) // is disable，skip broker list + goto skip; if (MESA_load_profile_string_def(profile, section, "mc_cache_broker_list", broker_list, sizeof(broker_list), NULL) < 0) { TFE_LOG_ERROR(g_default_logger, "%s, Fail to get mc_cache_broker_list in profile %s section %s.", errstr, profile, section); return -1; } +skip: g_kafka_logger = tfe_kafka_logger_create(enable, nic_name, broker_list, topic_name, g_default_logger); if (g_kafka_logger) return 0; |