Zhangao
Zhangao
@Demogorgon314 Do we have test can reproduce the error `Unexpected error code 7 while fetching data` before applying this pr?
@BewareMyPower PTAL
@hangc0276
Adjuest maxMessageSize and nettyMaxFrameSizeBytes doesn't make sense.
> Can you please give an example to step by step reproduce this bug? KOP 2.8.1.23 Pulsar 2.8 kafka client 2.4.1 1、I tried with FLINK to consume from topic A,...
> Could you try a smaller `maxReadEntriesNum` (like 1)? It was producer error, not consumer.
``` # # Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE file # distributed with this work for additional information...
@Demogorgon314
@hangc0276 I found when syncThread do flush, there exists duplicate `checkpointComplete` invoke. SyncThread flush: ``` private void flush() { Checkpoint checkpoint = checkpointSource.newCheckpoint(); try { ledgerStorage.flush(); } catch (NoWritableLedgerDirException e)...
> > 2.When bookie startup, read the minimal lastMark instead of the maximal lastMark as current last mark. > > @hangc0276 How is this logic implemented? Do you need to...