We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 34debe8 commit 848b057Copy full SHA for 848b057
src/main/java/org/radarbase/output/worker/RestructureWorker.kt
@@ -47,8 +47,13 @@ internal class RestructureWorker(
47
48
val numberFormat = NumberFormat.getNumberInstance()
49
50
- logger.info("Processing topic {}: converting {} files with {} records",
51
- topic, numberFormat.format(numFiles), numberFormat.format(numOffsets))
+ if (numOffsets == null) {
+ logger.info("Processing topic {}: converting {} files",
52
+ topic, numberFormat.format(numFiles))
53
+ } else {
54
+ logger.info("Processing topic {}: converting {} files with {} records",
55
+ topic, numberFormat.format(numFiles), numberFormat.format(numOffsets))
56
+ }
57
58
val seenOffsets = accountant.offsets
59
.withFactory { ReadOnlyFunctionalValue(it) }
0 commit comments