diff --git a/core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala b/core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala index 6de320d..e0b690a 100644 --- a/core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala +++ b/core/src/main/scala/kafka/javaapi/OffsetCommitRequest.scala @@ -28,7 +28,8 @@ class OffsetCommitRequest(groupId: String, val scalaMap: collection.mutable.Map[TopicAndPartition, OffsetAndMetadata] = { import collection.JavaConversions._ - collection.JavaConversions.asMap(requestInfo) + val immutable = requestInfo.toMap + collection.mutable.Map(immutable.toSeq:_*) } kafka.api.OffsetCommitRequest( groupId = groupId,