kafka TaskAssignor 源码

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

kafka SubscriptionInfo 源码

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

kafka StickyTaskAssignor 源码

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

kafka StandbyTaskAssignor 源码

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

kafka ReferenceContainer 源码

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