[
https://issues.apache.org/jira/browse/KAFKA-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YeLiang updated KAFKA-7880:
---------------------------
Description:
KafkaConnect will create a WorkerTask for tasks assigned to it and then submit
tasks to a thread pool.
However,the
[Worker|https://github.com/apache/kafka/blob/2.1.0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java]
class initializes its thread pool using a default ThreadFactory.So the thread
name will have a pattern pool-[0-9]-thread-[0-9].
When we are running KafkaConnect and find that one of the task thread is under
high CPU usage, it is difficult for us to find out which task is under high
load becasue when we print out
the stack of KafkaConnect, we can only see a list of threads name
pool-[0-9]-thread-[0-9] even if we can know the exact pid of the high CPU usage
thread
If worker threads name will be named like connectorName-taskId, it will be very
helpful
[HTTP|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension]
[,eitʃti:ti:'pi:]
[详细|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension]X
基本翻译
abbr. 超文本传输协议（Hyper Text Transport Protocol）
网络释义
[HTTP:|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension&le=eng]
超文本传输协议(Hyper Text Transfer Protocol)
[HTTP
referer:|http://dict.youdao.com/search?q=HTTP%20referer&keyfrom=chrome.extension&le=eng]
HTTP参照位址
[http
Proxy:|http://dict.youdao.com/search?q=http%20Proxy&keyfrom=chrome.extension&le=eng]
代理服务器
[有道词典|http://fanyi.youdao.com/translate?i=and%20print%20out%20the%20stack%20of%20KafkaConnect&keyfrom=chrome]
and print out t
...[详细|http://fanyi.youdao.com/translate?i=and%20print%20out%20the%20stack%20of%20KafkaConnect&smartresult=dict&keyfrom=chrome.extension]X
并打印KafkaConnect的堆栈
was:
KafkaConnect will create a WorkerTask for tasks assigned to it and then submit
tasks to a thread pool.
However,the
[Worker|https://github.com/apache/kafka/blob/2.1.0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java]
class initializes its thread pool using a default ThreadFactory.So the thread
name will have a pattern pool-[0-9]-thread-[0-9].
When we are running KafkaConnect and find that one of the task thread is under
high CPU usage, it is difficult for us to find out which task is under high
load becasue when we print out
the stack of KafkaConnect, we can only see a list of threads name
pool-[0-9]-thread-[0-9] even if we can know the exact pid of the high CPU usage
thread
If worker threads name will be named like connectorName-taskId, it will be very
helpful
{code:java}
{code}
[HTTP|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension]
[,eitʃti:ti:'pi:]
[详细|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension]X
基本翻译
abbr. 超文本传输协议（Hyper Text Transport Protocol）
网络释义
[HTTP:|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension&le=eng]
超文本传输协议(Hyper Text Transfer Protocol)
[HTTP
referer:|http://dict.youdao.com/search?q=HTTP%20referer&keyfrom=chrome.extension&le=eng]
HTTP参照位址
[http
Proxy:|http://dict.youdao.com/search?q=http%20Proxy&keyfrom=chrome.extension&le=eng]
代理服务器
[有道词典|http://fanyi.youdao.com/translate?i=and%20print%20out%20the%20stack%20of%20KafkaConnect&keyfrom=chrome]
and print out t
...[详细|http://fanyi.youdao.com/translate?i=and%20print%20out%20the%20stack%20of%20KafkaConnect&smartresult=dict&keyfrom=chrome.extension]X
并打印KafkaConnect的堆栈
> KafkaConnect should standardize worker thread name
> --------------------------------------------------
>
> Key: KAFKA-7880
> URL: https://issues.apache.org/jira/browse/KAFKA-7880
> Project: Kafka
> Issue Type: Improvement
> Components: KafkaConnect
> Affects Versions: 2.1.0
> Reporter: YeLiang
> Priority: Minor
> Fix For: 2.1.1
>
>
> KafkaConnect will create a WorkerTask for tasks assigned to it and then
> submit tasks to a thread pool.
> However,the
> [Worker|https://github.com/apache/kafka/blob/2.1.0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java]
> class initializes its thread pool using a default ThreadFactory.So the
> thread name will have a pattern pool-[0-9]-thread-[0-9].
> When we are running KafkaConnect and find that one of the task thread is
> under high CPU usage, it is difficult for us to find out which task is under
> high load becasue when we print out
> the stack of KafkaConnect, we can only see a list of threads name
> pool-[0-9]-thread-[0-9] even if we can know the exact pid of the high CPU
> usage thread
> If worker threads name will be named like connectorName-taskId, it will be
> very helpful
> [HTTP|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension]
> [,eitʃti:ti:'pi:]
> [详细|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension]X
> 基本翻译
> abbr. 超文本传输协议（Hyper Text Transport Protocol）
> 网络释义
> [HTTP:|http://dict.youdao.com/search?q=HTTP&keyfrom=chrome.extension&le=eng]
> 超文本传输协议(Hyper Text Transfer Protocol)
> [HTTP
> referer:|http://dict.youdao.com/search?q=HTTP%20referer&keyfrom=chrome.extension&le=eng]
> HTTP参照位址
> [http
> Proxy:|http://dict.youdao.com/search?q=http%20Proxy&keyfrom=chrome.extension&le=eng]
> 代理服务器
>
> [有道词典|http://fanyi.youdao.com/translate?i=and%20print%20out%20the%20stack%20of%20KafkaConnect&keyfrom=chrome]
> and print out t
> ...[详细|http://fanyi.youdao.com/translate?i=and%20print%20out%20the%20stack%20of%20KafkaConnect&smartresult=dict&keyfrom=chrome.extension]X
> 并打印KafkaConnect的堆栈
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
