Gordon Rennie

Add retries for schema registry errors

5

Fixes #663. Updated from abandoned PR #673: rebased to target 3.x and improved retry interface. Restructured PR description for readability ## Goal Prevent transient schema registry API errors from blowing...

Improve resilience of ser/des using Vulcan amd Schema Registry

3

Serialisation / deserialisation using vulcan codecs in `fs2-kafka-vulcan` requires communication with a Schema Registry REST API, implemented in Confluent's Java code which `fs2-kafka-vulcan` wraps. Transient problems communicating with the registry's...

Document safe usage conditions of `commitBatchWithin`

1

`CommittableOffsetBatch#commit` clearly explains some requirements for safe usage in its scaladoc: https://github.com/fd4s/fs2-kafka/blob/fcbb8b2011c40fc2e1fa4b86124e5f5d90548c8e/modules/core/src/main/scala/fs2/kafka/CommittableOffsetBatch.scala#L82-L95 It would be good to document these also in `fs2.kafka.commitBatchWithin`, which calls `CommittableOffsetBatch#commit` but does not document the...

I would like to create a new test configuration I consider distinct from integration tests, say `ServiceTest`: ```scala # build.sbt val ServiceTest = Configuration.of("ServiceTest", "servicetest").extend(IntegrationTest) lazy val root = (project...