mirror of https://github.com/apache/kafka.git
MINOR: Remove extraneous code in LocalLogManager (#12168)
Reviewers: Kvicii <Karonazaba@gmail.com>, dengziming <dengziming1993@gmail.com>, Divij Vaidya <divijvaidya13@gmail.com>
This commit is contained in:
parent
a1cd1d1839
commit
62ba4d3d4e
|
@ -243,11 +243,6 @@ public final class LocalLogManager implements RaftClient<ApiMessageAndVersion>,
|
||||||
}
|
}
|
||||||
|
|
||||||
public synchronized long append(LocalBatch batch) {
|
public synchronized long append(LocalBatch batch) {
|
||||||
try {
|
|
||||||
throw new RuntimeException("foo");
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.info("WATERMELON: appending {}", batch, e);
|
|
||||||
}
|
|
||||||
prevOffset += batch.size();
|
prevOffset += batch.size();
|
||||||
log.debug("append(batch={}, prevOffset={})", batch, prevOffset);
|
log.debug("append(batch={}, prevOffset={})", batch, prevOffset);
|
||||||
batches.put(prevOffset, batch);
|
batches.put(prevOffset, batch);
|
||||||
|
|
Loading…
Reference in New Issue