diff options
| author | fengweihao <[email protected]> | 2021-08-19 16:24:19 +0800 |
|---|---|---|
| committer | fengweihao <[email protected]> | 2021-08-19 16:24:19 +0800 |
| commit | c41a67ca2b410c13bfdc651af4992d8f8bc824e4 (patch) | |
| tree | f0eb6ca13e54be4bdeae3664fdc310a9da2fe443 /platform/src | |
| parent | 2a729a48b318faaa0ab1285a73b00e2cfed344c7 (diff) | |
TSG-7471 Proxy连接kafka时增加认证信息
Diffstat (limited to 'platform/src')
| -rw-r--r-- | platform/src/ssl_fetch_cert.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/platform/src/ssl_fetch_cert.cpp b/platform/src/ssl_fetch_cert.cpp index c2e48b5..61e97df 100644 --- a/platform/src/ssl_fetch_cert.cpp +++ b/platform/src/ssl_fetch_cert.cpp @@ -48,10 +48,15 @@ int ssl_mid_cert_kafka_logger_create(const char *profile, const char *section) char nic_name[64] = {0}; char broker_list[TFE_SYMBOL_MAX] = {0}; char topic_name[TFE_SYMBOL_MAX] = {0}; + char sasl_username[TFE_STRING_MAX] = {0}; + char sasl_passwd[TFE_STRING_MAX] = {0}; 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"); + MESA_load_profile_string_def(profile, section, "SASL_USERNAME", sasl_username, sizeof(sasl_username), ""); + MESA_load_profile_string_def(profile, section, "SASL_PASSWD", sasl_passwd, sizeof(sasl_passwd), ""); + if (!enable) goto skip; if (MESA_load_profile_string_def(profile, section, "mc_cache_broker_list", broker_list, sizeof(broker_list), NULL) < 0) @@ -60,7 +65,7 @@ int ssl_mid_cert_kafka_logger_create(const char *profile, const char *section) return -1; } skip: - g_kafka_logger = tfe_kafka_logger_create(enable, nic_name, broker_list, topic_name, g_default_logger); + g_kafka_logger = tfe_kafka_logger_create(enable, nic_name, broker_list, topic_name, sasl_username, sasl_passwd, g_default_logger); if (g_kafka_logger) return 0; else |