kafka SinkRecord 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
阅读全文
kafka SinkConnectorContext 源码
kafka SinkConnectorContext 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnectorContext.java
阅读全文
kafka SinkConnector 源码
kafka SinkConnector 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
阅读全文
kafka ErrantRecordReporter 源码
kafka ErrantRecordReporter 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java
阅读全文
kafka ConnectRestExtensionContext 源码
kafka ConnectRestExtensionContext 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtensionContext.java
阅读全文
kafka ConnectRestExtension 源码
kafka ConnectRestExtension 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java
阅读全文
kafka TaskState 源码
kafka TaskState 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
阅读全文
kafka ConnectorType 源码
kafka ConnectorType 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorType.java
阅读全文
kafka ConnectorState 源码
kafka ConnectorState 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorState.java
阅读全文
kafka ConnectorHealth 源码
kafka ConnectorHealth 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
阅读全文