fs2-kafka v0.19.2

Additions

• Add describeCluster and createTopics to KafkaAdminClient. Thanks @danxmoran! (#88)
• Add maxPrefetchBatches to ConsumerSettings. (#83)
  • Controls prefetching behaviour before backpressure kicks in.
  • Use withMaxPrefetchBatches to change the default setting.
• Add several constructs for working with record headers. (#85)
  • Add HeaderDeserializer for deserialization of record header values.
  • Add HeaderSerializer for serializing values to use as header values.
  • Add Header.serialize for serializing a value and creating a Header.
  • Add Header#headers for creating a Headers with a single Header.
  • Add Header#as and attemptAs for deserializing header values.
  • Add Headers#withKey and alias apply for extracting a single Header.
  • Add Headers#concat for concatenating another Headers instance.
  • Add Headers#asJava for converting to Java Kafka-compatible headers.
  • Add Headers.fromIterable to create Headers from Iterable[Header].
  • Add Headers.fromSeq to create Headers from Seq[Header].
• Add several constructs for working with record serialization. (#85)
  • Add a custom Serializer to make it easier to create and compose serializers.
  • Add a custom Deserializer to make it easier to create and compose deserializers.
  • Add ProducerSettings.apply for using implicit Serializers for the key and value.
  • Add ConsumerSettings.apply for using implicit Deserializers for the key and value.

Changes

• Change to make fs2.kafka.Id public. Thanks @chenharryhua! (#86, #87)

Updates

• Update Kafka to 2.1.1. Thanks @sebastianvoss! (#90, #91)

Documentation

• Add a technical details section explaining backpressure. Thanks @backuitist! (#82, #84)

Released on 2019-02-22.