diff options
Diffstat (limited to '')
| -rw-r--r-- | src/exporting/aws_kinesis/aws_kinesis.c (renamed from exporting/aws_kinesis/aws_kinesis.c) | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/exporting/aws_kinesis/aws_kinesis.c b/src/exporting/aws_kinesis/aws_kinesis.c index 498d9ee23..27f2fb0ba 100644 --- a/exporting/aws_kinesis/aws_kinesis.c +++ b/src/exporting/aws_kinesis/aws_kinesis.c @@ -100,6 +100,10 @@ void aws_kinesis_connector_worker(void *instance_p) struct aws_kinesis_specific_config *connector_specific_config = instance->config.connector_specific_config; struct aws_kinesis_specific_data *connector_specific_data = instance->connector_specific_data; + char threadname[ND_THREAD_TAG_MAX + 1]; + snprintfz(threadname, ND_THREAD_TAG_MAX, "EXPKNSS[%zu]", instance->index); + uv_thread_set_name_np(threadname); + while (!instance->engine->exit) { unsigned long long partition_key_seq = 0; struct stats *stats = &instance->stats; |