@Override
  public void fetchNextResponse(final long offset /* unused */) throws Exception {
    // generate and offer next response
    offer(generateNextTabletResponse());

    // poll and clean previous response
    final CachedSubscriptionPollResponse previousResponse;
    if (Objects.isNull(previousResponse = poll())) {
      LOGGER.warn(
          "SubscriptionEventTabletResponse {} is empty when fetching next response (broken invariant)",
          this);
    } else {
      previousResponse.closeMemoryBlock();
    }
  }
The {@code SubscriptionEventTabletResponse} class extends {@link
SubscriptionEventExtendableResponse} to handle subscription responses specifically for tablet
data. The actual payload of the response includes a {@link TabletsPayload}, which contains the
tablet information being processed.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/response/SubscriptionEventTabletResponse.java