Muenze
Muenze
Hi, the `retryExponentialBackoff` is defined in reactor-kotlin-extensions and uses reactor-extra as dependency. I don't want to retry the flux when the HTTP 429 occurs, what I really want is to...
Hi, sadly I was not able to really subclass it, because kotlin -> java code doesn't work that well and I had to copy over nearly everything. In the end...
``` public Mono execute(ReactiveElasticsearchClientCallback callback) { return this.hostProvider.getActive(Verification.LAZY) // .flatMap(callback::doWithClient) // .retryWhen( Retry.backoff(20, Duration.ofSeconds(2)) .filter(err -> err instanceof RestStatusException && ((RestStatusException)err).getStatus() == 429) ) .onErrorResume(throwable -> { if (isCausedByConnectionException(throwable)) {...
Kafka Avro Deserializer is not able to deserialize timestamps with "logicalType": "timestamp-micros"
We stumbled over this issue yesterday on prod. `"type" : ["null", {"type" : "long", "logicalType" : "timestamp-millis"}]` With Avro serializer version 7.5.0 it resulted in a proper Instant, with 7.5.1...
Kafka Avro Deserializer is not able to deserialize timestamps with "logicalType": "timestamp-micros"
Is this fixed now in 7.6.x? Sadly this one seemed to have gone unnoticed
Does anyone know if this has already been solved? We have communicated in our company that upgrading to 7.5.1 is very dangerous and nearly all the teams that did it...
It is a problem in 0.13.0, don't know why this is not being fixed... You have to set the region to your region in the options. My Problem was that...