in core/src/main/scala/org/apache/pekko/kafka/ConsumerMessage.scala [104:114]
def withMetadata(metadata: String) =
PartitionOffsetMetadata(key, offset, metadata)
override def toString = s"PartitionOffset(key=$key,offset=$offset)"
override def equals(other: Any): Boolean = other match {
case that: PartitionOffset =>
that.canEqual(this) && Objects.equals(this.key, that.key) &&
Objects.equals(this.offset, that.offset)
case _ => false
}