2022-03-31 10:34:41,546 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-3] org.apache.kafka.streams.processor.internals.StreamTask: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-3] task [7_2] Closed clean
2022-03-31 10:34:41,628 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-2] org.apache.kafka.streams.processor.internals.StreamThread: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-2] State transition from PENDING_SHUTDOWN to DEAD
2022-03-31 10:34:41,628 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-2] org.apache.kafka.streams.processor.internals.StreamThread: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-2] Shutdown complete
2022-03-31 10:34:41,646 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-1] org.apache.kafka.streams.processor.internals.StreamThread: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD
2022-03-31 10:34:41,646 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-1] org.apache.kafka.streams.processor.internals.StreamThread: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-1] Shutdown complete
2022-03-31 10:34:41,647 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-3] org.apache.kafka.streams.processor.internals.StreamThread: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-3] State transition from PENDING_SHUTDOWN to DEAD
2022-03-31 10:34:41,647 INFO  [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-3] org.apache.kafka.streams.processor.internals.StreamThread: stream-thread [test-test-run-kpi-f3555a21-409c-45a2-af8e-171981da2716-StreamThread-3] Shutdown complete
2022-03-31 10:34:41,653 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 1_0 for 1_0 as user calling cleanup.
2022-03-31 10:34:41,658 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 7_2 for 7_2 as user calling cleanup.
2022-03-31 10:34:41,658 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 5_1 for 5_1 as user calling cleanup.
2022-03-31 10:34:41,659 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 1_1 for 1_1 as user calling cleanup.
2022-03-31 10:34:41,661 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 3_2 for 3_2 as user calling cleanup.
2022-03-31 10:34:41,663 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 5_0 for 5_0 as user calling cleanup.
2022-03-31 10:34:41,663 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 4_2 for 4_2 as user calling cleanup.
2022-03-31 10:34:41,665 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 6_1 for 6_1 as user calling cleanup.
2022-03-31 10:34:41,665 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 2_0 for 2_0 as user calling cleanup.
2022-03-31 10:34:41,666 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 6_0 for 6_0 as user calling cleanup.
2022-03-31 10:34:41,666 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 2_1 for 2_1 as user calling cleanup.
2022-03-31 10:34:41,667 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 0_2 for 0_2 as user calling cleanup.
2022-03-31 10:34:41,667 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 7_1 for 7_1 as user calling cleanup.
2022-03-31 10:34:41,667 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 5_2 for 5_2 as user calling cleanup.
2022-03-31 10:34:41,668 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 3_0 for 3_0 as user calling cleanup.
2022-03-31 10:34:41,670 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 7_0 for 7_0 as user calling cleanup.
2022-03-31 10:34:41,671 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 1_2 for 1_2 as user calling cleanup.
2022-03-31 10:34:41,673 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 3_1 for 3_1 as user calling cleanup.
2022-03-31 10:34:41,675 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 0_0 for 0_0 as user calling cleanup.
2022-03-31 10:34:41,675 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 4_1 for 4_1 as user calling cleanup.
2022-03-31 10:34:41,680 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 6_2 for 6_2 as user calling cleanup.
2022-03-31 10:34:41,680 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 2_2 for 2_2 as user calling cleanup.
2022-03-31 10:34:41,680 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 0_1 for 0_1 as user calling cleanup.
2022-03-31 10:34:41,681 INFO  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Deleting task directory 4_0 for 4_0 as user calling cleanup.
2022-03-31 10:34:41,689 WARN  [SpringApplicationShutdownHook] org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread [SpringApplicationShutdownHook] Failed to delete state store directory of /kafka-streams-statestore/555b9965-95e3-4c92-b467-1d283428da5d/test-test-run-kpi for it is not empty