docs: @Override
      public void finish(IQueueMessage<ID, DATA> msg) {
          if (!isEphemeralDisabled()) {
              String key = msg.getId().toString();
              rocksDbWrapper.delete(cfNameEphemeral, writeOptions, key);
          }
      }