Some clarifications about the blog post

[ghenadiibatalski]

Hello and thank you for a good post and explaination there. I've got some questions while reading it.

1. What is exactly the bug handled by Flux.defer(receiver::receive)? Could you please give a hint? Are any side effects known on defer other than polluting the code with unnecessary instructions?
2. I hoped to handle deserialization errors by doOnError callback, but this was not the case. I ended up using the ErrorHandlingDeserializer2. Do you have any hints on handling of this kind of errors.

Thank you and kind regards,
Gena

PS. Sorry for that, but i don't have rights to contact you via medium.com directly so i propose the questions as an issue. Possibly the answer could also interest other developers ;-)

[haigopi]

Thanks for reaching.
What is exactly the bug handled by Flux.defer(receiver::receive)? Could you please give a hint? Are any side effects known on defer other than polluting the code with unnecessary instructions?

Reactror Kafka, Randomly failing to receive the events. When I wrote this, it was reported and as a workaround Flex.defer came in handy.

I hoped to handle deserialization errors by doOnError callback, but this was not the case. I ended up using the ErrorHandlingDeserializer2. Do you have any hints on handling of this kind of errors.

You may not need the original object altogether. If you need, You can still pass the original Object.
https://github.com/haigopi/ReactorKafkaExample/blob/52392dfc6d0a380c37df7c116407611296cc4254/src/main/java/com/allibilli/recator/functional/ErrorHandlerFunction.java