kafka TransactionContext 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/TransactionContext.java
阅读全文
kafka SourceTaskContext 源码
kafka SourceTaskContext 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
阅读全文
kafka SourceTask 源码
kafka SourceTask 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java
阅读全文
kafka SourceRecord 源码
kafka SourceRecord 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
阅读全文
kafka SourceConnectorContext 源码
kafka SourceConnectorContext 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java
阅读全文
kafka SourceConnector 源码
kafka SourceConnector 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
阅读全文
kafka ExactlyOnceSupport 源码
kafka ExactlyOnceSupport 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/ExactlyOnceSupport.java
阅读全文
kafka ConnectorTransactionBoundaries 源码
kafka ConnectorTransactionBoundaries 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/source/ConnectorTransactionBoundaries.java
阅读全文
kafka SinkTaskContext 源码
kafka SinkTaskContext 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
阅读全文
kafka SinkTask 源码
kafka SinkTask 代码
文件路径:/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java
阅读全文