gfwleak/tango-tsg-master
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TSG-7607: 适配TOPIC名称变更

Browse Source
This commit is contained in:
liuxueli
2021-09-02 15:15:15 +08:00
parent 98031e1504
commit 093c02e3f0
2 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
bin/tsg_log_field.conf
View File

@@ -1,14 +1,13 @@
#TYPE：1:UCHAR,2:USHORT,3:ULONG,4:ULOG,5:USTRING,6:FILE,7:UBASE64,8:PACKET #TYPE：1:UCHAR,2:USHORT,3:ULONG,4:ULOG,5:USTRING,6:FILE,7:UBASE64,8:PACKET
#TYPE TOPIC SERVICE #TYPE TOPIC SERVICE
TOPIC SECURITY-EVENT-LOG 0 TOPIC SECURITY-EVENT 0
TOPIC SECURITY-EVENT-LOG 1 TOPIC SECURITY-EVENT 1
TOPIC CONNECTION-RECORD-LOG 2 TOPIC SESSION-RECORD 2
TOPIC CONNECTION-SKETCH 3 TOPIC INTERNAL-RTP-RECORD 4
TOPIC INTERNAL-RTP-LOG 4 TOPIC VOIP-RECORD 5
TOPIC VOIP-RECORD-LOG 5 TOPIC INTERIM-SESSION-RECORD 6
TOPIC LIVE-SESSION-RECORD-LOG 6 TOPIC TRANSACTION-RECORD 7
TOPIC TRANSACTION-RECORD-LOG 7 TOPIC GTPC-RECORD 8
TOPIC GTPC-RECORD-LOG 8
#TYPE FIELD VALUE #TYPE FIELD VALUE
LONG common_policy_id 1 LONG common_policy_id 1

2
src/tsg_send_log.cpp
View File

@@ -1464,7 +1464,7 @@ struct tsg_log_instance_t *tsg_sendlog_init(const char *conffile)
rd_kafka_conf_set(rdkafka_conf, "socket.keepalive.enable", "true", kafka_errstr, sizeof(kafka_errstr)); rd_kafka_conf_set(rdkafka_conf, "socket.keepalive.enable", "true", kafka_errstr, sizeof(kafka_errstr));
rd_kafka_conf_set(rdkafka_conf, "bootstrap.servers", _instance->broker_list, kafka_errstr, sizeof(kafka_errstr)); rd_kafka_conf_set(rdkafka_conf, "bootstrap.servers", _instance->broker_list, kafka_errstr, sizeof(kafka_errstr));
if(strlen(_instance->sasl_passwd)> 0 && strlen(_instance->sasl_passwd)>0) if(strlen(_instance->sasl_username)> 0 && strlen(_instance->sasl_passwd)>0)
{ {
rd_kafka_conf_set(rdkafka_conf, "security.protocol", "sasl_plaintext", kafka_errstr, sizeof(kafka_errstr)); rd_kafka_conf_set(rdkafka_conf, "security.protocol", "sasl_plaintext", kafka_errstr, sizeof(kafka_errstr));
rd_kafka_conf_set(rdkafka_conf, "sasl.mechanisms", "PLAIN", kafka_errstr, sizeof(kafka_errstr)); rd_kafka_conf_set(rdkafka_conf, "sasl.mechanisms", "PLAIN", kafka_errstr, sizeof(kafka_errstr));