diff options
| author | 李仁杰 <[email protected]> | 2020-08-20 12:12:55 +0800 |
|---|---|---|
| committer | 李仁杰 <[email protected]> | 2020-08-20 12:12:55 +0800 |
| commit | 2d45f7205f9ae06a3fae47c2c4d7c0e99d5d4821 (patch) | |
| tree | fac053d6d723babae4ad1e0bd5ed27a42668e64e | |
| parent | 782e778e7d7e206d7192a70cffdfd0ca20619271 (diff) | |
Update lirenjie_vxlan_sapp_20200803.c 20200820
| -rw-r--r-- | lirenjie_vxlan_sapp_20200803.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lirenjie_vxlan_sapp_20200803.c b/lirenjie_vxlan_sapp_20200803.c index f980e2f..fbea892 100644 --- a/lirenjie_vxlan_sapp_20200803.c +++ b/lirenjie_vxlan_sapp_20200803.c @@ -33,8 +33,8 @@ extern int g_business_plug_type; #define ENABLE_COUNT_THREAD 1 //是否启用统计功能.added by lrj at 20200803 #define ENABLE_GSJ_THREAD 0 //是否启用GSJ -#define ENABLE_TIMER 1 - +#define ENABLE_TIMER 0 +#define ENABLE_KAFKA 1 //是否向G_BACK_TRAFFIC_STATISTIC_new发数据 #define MAX_LOG_INFO_LEN 256 #define MAX_VPN_ID_NUM 512 #define MAX_TRAFFIC_INFO_LEN 1024 @@ -692,7 +692,9 @@ static void print_traffic_info(struct traffic_info *tinfo, struct streaminfo *ps default: break; } +#if ENABLE_KAFKA push_data_to_kafka(info, strlen(info), rkt_traffic_stat); +#endif #if ENABLE_GSJ_THREAD if (push_buffer_count[thread_seq] == PUSH_BUFFER_COUNT) |