[GitHub] [kafka] guozhangwang commented on a change in pull request #8962: KAFKA-10166: checkpoint recycled standbys and ignore empty rocksdb base directory

2020-07-06 Thread GitBox
guozhangwang commented on a change in pull request #8962: URL: https://github.com/apache/kafka/pull/8962#discussion_r450471701 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -270,8 +270,11 @@ public void handleAssignment

[GitHub] [kafka] guozhangwang commented on a change in pull request #8962: KAFKA-10166: checkpoint recycled standbys and ignore empty rocksdb base directory

2020-07-06 Thread GitBox
guozhangwang commented on a change in pull request #8962: URL: https://github.com/apache/kafka/pull/8962#discussion_r450471701 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -270,8 +270,11 @@ public void handleAssignment

[GitHub] [kafka] guozhangwang commented on a change in pull request #8962: KAFKA-10166: checkpoint recycled standbys and ignore empty rocksdb base directory

2020-07-04 Thread GitBox
guozhangwang commented on a change in pull request #8962: URL: https://github.com/apache/kafka/pull/8962#discussion_r449799110 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java ## @@ -270,8 +270,11 @@ public void handleAssignment