diff --git a/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala b/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala index c2d953f..b726a7e 100644 --- a/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala +++ b/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala @@ -30,7 +30,7 @@ import java.io._ */ object HighwaterMarkCheckpoint { - val highWatermarkFileName = ".highwatermark" + val highWatermarkFileName = "replication-offset-checkpoint" val currentHighwaterMarkFileVersion = 0 }