diff options
| author | tongzongzhen <[email protected]> | 2024-05-24 11:27:47 +0800 |
|---|---|---|
| committer | tongzongzhen <[email protected]> | 2024-05-24 11:27:47 +0800 |
| commit | 80f72348cc78709f57f177424021402dd514f366 (patch) | |
| tree | 9df602f2d95d6bae59a745cdc568317bca2fdc69 /src/trace_output.c | |
| parent | 5752ca8b51651a942542922bcb2c699f226f041c (diff) | |
add kafka queue size as config
Diffstat (limited to 'src/trace_output.c')
| -rw-r--r-- | src/trace_output.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/trace_output.c b/src/trace_output.c index ffc1961..d32bf65 100644 --- a/src/trace_output.c +++ b/src/trace_output.c @@ -87,7 +87,8 @@ void dp_trace_output_init() DP_TRACE_VERIFY(ret == 0, "pthread_mutex_init failed(ret = % d)", ret); } - kafka_handle = kafka_handle_create(conf->broker_list, conf->sasl_username, conf->sasl_password); + kafka_handle = + kafka_handle_create(conf->broker_list, conf->sasl_username, conf->sasl_password, conf->kafka_queue_size); kafka_topic = kafka_topic_new(kafka_handle, conf->topic_name, NULL); for (unsigned int i = 0; i < TELEMETRY_DIM(dp_trace_output); i++) |