kafka TopicStatus 源码

kafka TopicStatus 代码 文件路径:/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java
阅读全文

kafka TaskStatus 源码

kafka TaskStatus 代码 文件路径:/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java
阅读全文

kafka TaskConfig 源码

kafka TaskConfig 代码 文件路径:/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java
阅读全文

kafka TargetState 源码

kafka TargetState 代码 文件路径:/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TargetState.java
阅读全文

kafka StateTracker 源码

kafka StateTracker 代码 文件路径:/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java
阅读全文