Merge branch 'main' into cn/gather-files-to-compact
commit
b836c6bced
|
@ -194,7 +194,7 @@ impl IngestHandlerImpl {
|
||||||
.stream_handler(kafka_partition.get() as u32)
|
.stream_handler(kafka_partition.get() as u32)
|
||||||
.await
|
.await
|
||||||
.context(WriteBufferSnafu)?;
|
.context(WriteBufferSnafu)?;
|
||||||
debug!(
|
info!(
|
||||||
kafka_partition = kafka_partition.get(),
|
kafka_partition = kafka_partition.get(),
|
||||||
min_unpersisted_sequence_number = sequencer.min_unpersisted_sequence_number.get(),
|
min_unpersisted_sequence_number = sequencer.min_unpersisted_sequence_number.get(),
|
||||||
"Seek stream",
|
"Seek stream",
|
||||||
|
|
Loading…
Reference in New Issue