Merge pull request #372 from Eistern/bugfix/fix-write-in-tx-case

Handle write acks from YDB server during transactions

Author: alex268

bom/pom.xml

@@ -15,7 +15,7 @@
 
     <properties>
         <ydb-auth-api.version>1.0.0</ydb-auth-api.version>
-        <ydb-proto-api.version>1.6.4</ydb-proto-api.version>
+        <ydb-proto-api.version>1.7.0</ydb-proto-api.version>
         <yc-auth.version>2.2.0</yc-auth.version>
     </properties>
 

topic/src/main/java/tech/ydb/topic/write/WriteAck.java

@@ -16,7 +16,8 @@ public WriteAck(long seqNo, State state, Details details) {
 
     public enum State {
         WRITTEN,
-        ALREADY_WRITTEN
+        ALREADY_WRITTEN,
+        WRITTEN_IN_TX
     }
 
     public static class Details {

topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java

@@ -516,7 +516,9 @@ private void processWriteAck(EnqueuedMessage message,
                             return;
                     }
                     break;
-
+                case WRITTEN_IN_TX:
+                    resultAck = new WriteAck(ack.getSeqNo(), WriteAck.State.WRITTEN_IN_TX, null);
+                    break;
                 default:
                     message.getFuture().completeExceptionally(
                             new RuntimeException("Unknown WriteAck state"));