code: @Override
      public CompletableFuture<Void> append(String streamSegmentName, byte[] data, Collection<AttributeUpdate> attributeUpdates, Duration timeout) {
          return invoke(
                  streamSegmentName,
                  container -> container.append(streamSegmentName, data, attributeUpdates, timeout),
                  "append", streamSegmentName, data.length, attributeUpdates);
      }
docs: region StreamSegmentStore Implementation