[2020-05-24 17:24:56,442] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2 INFO task [0_1] Checkpointable offsets read from checkpoint: {test-app-dedup-store-changelog-1=1} (org.apache.kafka.st
reams.processor.internals.ProcessorStateManager:113)
[2020-05-24 17:24:56,442] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-1 INFO standby-task [0_1] Writing checkpoint: {test-app-dedup-store-changelog-1=1} (org.apache.kafka.streams.processor.i
nternals.ProcessorStateManager:358)
[2020-05-24 17:24:56,443] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2 INFO task [0_1] eosEnabled checkpointFile.delete() (org.apache.kafka.streams.processor.internals.ProcessorStateManager
:118)
streams.state.internals.OffsetCheckpoint:185)
ssor.internals.ProcessorStateManager:313)
sorStateManager:123)
[2020-05-24 17:24:56,443] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2 INFO delete offset checkpoint /tmp/kafka-streams/instance-2/test-app/0_1/.checkpoint, exists: true (org.apache.kafka.s
treams.state.internals.OffsetCheckpoint:185)
[2020-05-24 17:24:56,443] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-1 TRACE Writing tmp checkpoint file /tmp/kafka-streams/instance-2/test-app/0_1/.checkpoint.tmp (org.apache.kafka.streams
.state.internals.OffsetCheckpoint:81)
teManager:317)
        currently assigned active tasks: []
        currently assigned standby tasks: [0_0, 0_2]
        revoked active tasks: []
        revoked standby tasks: []
 (org.apache.kafka.streams.processor.internals.StreamThread:96)
[2020-05-24 17:24:56,444] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2 DEBUG task [0_1] Created state store manager for task 0_1 (org.apache.kafka.streams.processor.internals.ProcessorStateManager:123)
[2020-05-24 17:24:56,444] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2 INFO stream-thread [test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2] Creating producer client for task 0_1 (org.apache.kafka.streams.processor.internals.StreamThread:370)
[2020-05-24 17:24:56,444] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-1 TRACE Swapping tmp checkpoint file /tmp/kafka-streams/instance-2/test-app/0_1/.checkpoint.tmp /tmp/kafka-streams/instance-2/test-app/0_1/.checkpoint (org.apache.kafka.streams.state.internals.OffsetCheckpoint:97)
[2020-05-24 17:24:56,444] test-app-4e6ae5d2-8be3-4f65-83e3-5e6e124fe94d-StreamThread-2 INFO ProducerConfig values: