@Override
  @Before
  public void setUp() throws Exception {
    super.setUp();
    createDB(database);
    createTopic_s(
        topicName, pattern, "2024-01-01T00:00:00+08:00", "2024-03-01T00:00:00+08:00", false);
    session_src.createTimeseries(
        pattern, TSDataType.INT32, TSEncoding.GORILLA, CompressionType.SNAPPY);
    session_src.createTimeseries(
        device + ".`BJ-ABH#01`", TSDataType.BOOLEAN, TSEncoding.RLE, CompressionType.LZMA2);
    schemaList.add(new MeasurementSchema("`ABH#01`", TSDataType.INT32));
    schemaList.add(new MeasurementSchema("`BJ-ABH#01`", TSDataType.BOOLEAN));
    System.out.println("topics:" + subs.getTopics());
    assertTrue(subs.getTopic(topicName).isPresent(), "Create show topics");
  }
Sequence-level topic, with start, end, tsfile
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/treemodel/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java