+ if (data.offsets[partition] == 0)
+ {
+ // Initialize the state of the partition, if
+ // no corresponding offset is known.
+ if (data.mappings[partition] != null)
+ log.warn(
+ "dropping state for partition {} ({} entries), because the corresponding offset is unknown!",
+ partition,
+ data.mappings[partition].size());
+
+ data.mappings[partition] = new HashMap<>();
+ }
+