[KAFKA-6407] Sink task metrics are the same for all connectors - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Minor
Resolution: Duplicate
Affects Version/s: 1.0.0
Fix Version/s: None
Component/s: connect
Labels:
None

Description

I have a lot of sink connectors inside a distributed worker. When I tried to save metrics to graphite I discovered all task metrics are identical.

$>get -b kafka.connect:type=sink-task-metrics,connector=prom-by-catalog-company,task=0 sink-record-read-total
#mbean = kafka.connect:type=sink-task-metrics,connector=prom-by-catalog-company,task=0:
sink-record-read-total = 228744.0;

$>get -b kafka.connect:type=sink-task-metrics,connector=prom-kz-catalog-product,task=0 sink-record-read-total
#mbean = kafka.connect:type=sink-task-metrics,connector=prom-kz-catalog-product,task=0:
sink-record-read-total = 228744.0;

$>get -b kafka.connect:type=sink-task-metrics,connector=prom-ru-catalog-company,task=0 sink-record-read-total
#mbean = kafka.connect:type=sink-task-metrics,connector=prom-ru-catalog-company,task=0:
sink-record-read-total = 228744.0;