package object kafka {
  implicit class NicerCommittable(val underlying: Committable) extends AnyVal {
    def commit(): Future[Done] = underlying.commitScaladsl()
  }
}