kafka StreamThread 源码

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

kafka StreamTask 源码

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

kafka StateUpdater 源码

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

kafka StateManager 源码

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