kafka SinkRecord 源码

kafka SinkRecord 代码 文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
阅读全文

kafka TaskState 源码

kafka TaskState 代码 文件路径:/connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
阅读全文