[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r764012303 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java ## @@ -0,0 +1,236 @@ +/* + * Licensed to

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r762030366 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java ## @@ -0,0 +1,236 @@ +/* + * Licensed to

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r761883799 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,38 @@ +/* + * L

[GitHub] [kafka] vpapavas commented on a change in pull request #11513: feat: Write and restore position to/from changelog

vpapavas commented on a change in pull request #11513: URL: https://github.com/apache/kafka/pull/11513#discussion_r761883799 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java ## @@ -0,0 +1,38 @@ +/* + * L