Skip to content

Commit

Permalink
KAFKA-14584: Deprecate StateChangeLogMerger tool (#13171)
Browse files Browse the repository at this point in the history
Reviewers: Mickael Maison <mickael.maison@gmail.com>
  • Loading branch information
fvaleri committed Apr 28, 2023
1 parent d796480 commit 10b3e66
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions core/src/main/scala/kafka/tools/StateChangeLogMerger.scala
Original file line number Diff line number Diff line change
Expand Up @@ -44,9 +44,8 @@ import org.apache.kafka.server.util.CommandLineUtils
* 3. Start time from when the logs should be merged
* 4. End time until when the logs should be merged
*/

@deprecated(since = "3.6")
object StateChangeLogMerger extends Logging {

val dateFormatString = "yyyy-MM-dd HH:mm:ss,SSS"
val topicPartitionRegex = new Regex("\\[(" + Topic.LEGAL_CHARS + "+),( )*([0-9]+)\\]")
val dateRegex = new Regex("[0-9]{4}-[0-9]{2}-[0-9]{2} [0-9]{2}:[0-9]{2}:[0-9]{2},[0-9]{3}")
Expand All @@ -58,6 +57,7 @@ object StateChangeLogMerger extends Logging {
var endDate: Date = _

def main(args: Array[String]): Unit = {
println("WARNING: This tool is deprecated and will be removed in the next major release.")

// Parse input arguments.
val parser = new OptionParser(false)
Expand Down Expand Up @@ -192,5 +192,4 @@ object StateChangeLogMerger extends Logging {
secondDate.compareTo(firstDate)
}
}

}

0 comments on commit 10b3e66

Please sign in to comment.