diff --git a/src/main/scala/com/github/splee/burrower/OffsetMonitor.scala b/src/main/scala/com/github/splee/burrower/OffsetMonitor.scala
index e6715c7..1a67f23 100644
--- a/src/main/scala/com/github/splee/burrower/OffsetMonitor.scala
+++ b/src/main/scala/com/github/splee/burrower/OffsetMonitor.scala
@@ -62,7 +62,7 @@ class OffsetMonitor (
   writer: Writer
 ) extends Runnable with LazyLogging {
 
-  val burrowBaseUrl = f"http://$burrowHost:$burrowPort/v2/kafka"
+  val burrowBaseUrl = f"http://$burrowHost:$burrowPort/v3/kafka"
 
   def run(): Unit = {
     while (true) {