Skip to content

fs2-kafka v0.19.3

Compare
Choose a tag to compare
@vlovgr vlovgr released this 27 Feb 10:23

Additions

  • Add functions for working with consumer offsets. Thanks @backuitist! (#92, #93)
    • Add KafkaConsumer#assignment.
    • Add KafkaConsumer#position.
    • Add KafkaConsumer#seekToBeginning.
    • Add KafkaConsumer#seekToEnd.
  • Add Attempt[A] aliases for deserializers. (#95)
    • Add Deserializer.Attempt[A] = Deserializer[Either[Throwable, A]].
    • Add HeaderDeserializer.Attempt[A] = HeaderDeserializer[Either[Throwable, A]].

Released on 2019-02-27.