kafka RecordQueue 源码

kafka RecordQueue 代码 文件路径：/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java
2022-10-20 208 大数据
阅读全文

kafka RecordCollector 源码

kafka RecordCollector 代码 文件路径：/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java
2022-10-20 205 大数据
阅读全文

kafka ReadOnlyTask 源码

kafka ReadOnlyTask 代码 文件路径：/streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java
2022-10-20 323 大数据
阅读全文

kafka QuickUnion 源码

kafka QuickUnion 代码 文件路径：/streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java
2022-10-20 225 大数据
阅读全文
↑