Upgrade kafka to use 1.1.1 (#54)

* upgrade kafka to use 1.1.1

* upgrade kafka test to use 1.1.0

Author: marky-mark

build.sbt

@@ -54,11 +54,11 @@ libraryDependencies ++= Seq(
   "org.slf4j"                     % "log4j-over-slf4j"              % "1.7.22",
   "org.scalaz"                    %% "scalaz-core"                  % "7.2.8",
   "com.typesafe.play"             %% "play-json"                    % "2.6.2",
-  "org.apache.kafka"              %% "kafka"                        % "1.0.0",
+  "org.apache.kafka"              %% "kafka"                        % "1.1.1",
   "com.typesafe.akka"             %% "akka-http-testkit"            % "10.0.5"  % "test",
   "org.scalatest"                 %% "scalatest"                    % "2.2.4"   % "test",
   "org.scalamock"                 %% "scalamock-scalatest-support"  % "3.6.0"   % "test",
-  "net.manub"                     %% "scalatest-embedded-kafka"     % "1.0.0"   % "test"
+  "net.manub"                     %% "scalatest-embedded-kafka"     % "1.1.0"   % "test"
 )
 
 excludeDependencies ++= Seq(

src/main/scala/RemoraKafkaConsumerGroupService.scala

@@ -59,7 +59,7 @@ class RemoraKafkaConsumerGroupService(kafkaSettings: KafkaSettings)
     describeTimer.time {
       val kafkaConsumerGroupService = createKafkaConsumerGroupService(Some(group))
       try {
-        val (state, assignments) = kafkaConsumerGroupService.describeGroup()
+        val (state, assignments) = kafkaConsumerGroupService.collectGroupOffsets()
         assignments match {
           case Some(partitionAssignmentStates) =>
             val assignments = Some(partitionAssignmentStates.map(a => PartitionAssignmentState(a.group,