Suggested refactor in GetCommittedOffsets#getResponse

akka · Mar 4, 2020 · 547f38a · 547f38a
1 parent 7e8c649
commit 547f38a
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/core/src/main/scala/akka/kafka/Metadata.scala b/core/src/main/scala/akka/kafka/Metadata.scala
@@ -205,11 +205,7 @@ object Metadata {
      * Java API
      */
     def getResponse: Optional[java.util.Map[TopicPartition, OffsetAndMetadata]] =
-      response
-        .map { m =>
-          Optional.of(m.asJava)
-        }
-        .getOrElse(Optional.empty())
+      Optional.ofNullable(response.toOption.map(_.asJava).orNull)
   }
 
   /**