diff --git a/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala b/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala index 30caec1..af17932 100644 --- a/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala +++ b/core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala @@ -36,7 +36,7 @@ object HighwaterMarkCheckpoint { class HighwaterMarkCheckpoint(val path: String) extends Logging { /* create the highwatermark file handle for all partitions */ - val name = path + "/" + HighwaterMarkCheckpoint.highWatermarkFileName + val name = path + File.separator + HighwaterMarkCheckpoint.highWatermarkFileName private val hwFile = new File(name) private val hwFileLock = new ReentrantLock() // recover from previous tmp file, if required