tamer

tamer copied to clipboard

Updates [dev.zio:zio-kafka](https://github.com/zio/zio-kafka/) from 0.17.7 to 2.0.1. [GitHub Release Notes](https://github.com/zio/zio-kafka/releases/tag/v2.0.1) - [Version Diff](https://github.com/zio/zio-kafka/compare/v0.17.7...v2.0.1) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd...

scala-steward

https://github.com/laserdisc-io/tamer/blob/8c8c40ff1f17b3735d44349797257600bdf31f15/example/src/main/scala/tamer/rest/RESTCustomAuth.scala#L21 This can result in code like this for custom auth: ``` val authentication: Authentication[Any] = new Authentication[Any] { override def addAuthentication(request: SttpRequest, supplementalSecret: Option[String]): SttpRequest = // ... }...

gurghet

sirocchj

https://github.com/laserdisc-io/tamer/blob/a1a33f5aac8bba4a76e4294fd63b967182e5b586/core/src/main/scala/tamer/Tamer.scala#L128 A nice enhancement would be to peek into the kafka producer config, get the transaction timeout and issue a human readable warning in case the transaction is still open,...

gurghet

https://github.com/laserdisc-io/tamer/blob/0a539b788976e932874dc8ce130ed1930f74d975/core/src/main/scala/tamer/Setup.scala#L18 https://github.com/laserdisc-io/tamer/blob/0a539b788976e932874dc8ce130ed1930f74d975/core/src/main/scala/tamer/Setup.scala#L16 Here `TamerError` leaks to the user, a quick and dirty solution would be to widen to a `RIO`

gurghet

After #540 there are no more checks of the state topic in case of crashes. On one hand the cases are greatly reduced by the introduction of transactionality, on the...

gurghet

Backoff when caught up

2

Tamer is designed to always go as fast as possible. Sometimes it may be desirable to slow down, e.g. once we caught up with the "initial load".. We could use...

sirocchj

The field below, while logically belongs to core, it's never used by it and only used by the modules. This is just code smell and not a real problem but...

gurghet

Expose health check endpoint

2

https://kubernetes.io/docs/tasks/configure-pod-container/configure-liveness-readiness-startup-probes/#define-a-liveness-http-request

sirocchj

## About this PR 📦 Updates [org.apache.kafka:kafka-clients](https://kafka.apache.org) from `3.6.1` to `3.6.2` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as you don't change...

scala-steward