Skip to content

Instantly share code, notes, and snippets.

@dwestheide

dwestheide/kafka.scala

Created October 25, 2016 07:25
Show Gist options
  • Save dwestheide/482d0ded9e905f99efb3ff9a4e5afd53 to your computer and use it in GitHub Desktop.
Save dwestheide/482d0ded9e905f99efb3ff9a4e5afd53 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka.scala
package object kafka {
implicit class NicerCommittable(val underlying: Committable) extends AnyVal {
def commit(): Future[Done] = underlying.commitScaladsl()
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment