KAFKA-9066: Retain metrics for failed tasks (#8502) (#8854)
Author: Chris Egerton <chrise@confluent.io> Reviewers: Nigel Liang <nigel@nigelliang.com>, Konstantine Karantasis <konstantine@confluent.io>, Randall Hauch <rhauch@gmail.com>
显示
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java 6 个添加, 1 个删除...rc/main/java/org/apache/kafka/connect/runtime/Worker.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java 6 个添加, 2 个删除...java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java 6 个添加, 2 个删除...va/org/apache/kafka/connect/runtime/WorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java 10 个添加, 17 个删除...ain/java/org/apache/kafka/connect/runtime/WorkerTask.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java 0 个添加, 9 个删除...java/org/apache/kafka/connect/runtime/WorkerTaskTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java 12 个添加, 0 个删除...est/java/org/apache/kafka/connect/runtime/WorkerTest.java
加载中
想要评论请 注册 或 登录