From 7fa581d213eae0ae6fb06c66fc930a12bdd698c2 Mon Sep 17 00:00:00 2001
From: rurs16 <43678940+rurs16@users.noreply.github.com>
Date: Fri, 28 Sep 2018 10:01:34 -0500
Subject: [PATCH] Burrow BaseURL change needed for upgraded burrow

Burrow upgrade has changed their base url to "http://$burrowHost:$burrowPort/v3/kafka". Burrower needs to be re-compiled with this new config. Please verify and merge
---
 src/main/scala/com/github/splee/burrower/OffsetMonitor.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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) {