wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r563652131
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(fina
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r563652356
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
##
@@ -115,22 +115,29 @@ public void shouldCrea
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r563652131
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(fina
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r562482975
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(fina
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r562467953
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
##
@@ -115,22 +115,29 @@ public void shouldCrea
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r562467278
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(fina
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r562466134
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(fina
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r562464755
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(fina