Add a deserializer that return Either[ConsumerRecord[K, T], T]

[filosganga]

In some cases, you want to have the original ConsumerRecord when the deserialization fails. At the moment it is not possible.

We would like to write a deserializer that given a ConsumerRecord[K, V] will return Either[ConsumerRecord[K,V], V] for the value (Or Either[ConsumerRecord[K,V], V] for the Key).

[PiotrFras]

You might want to include the actual error (throwable) on the left side too.

final case class ConsumerFailure[K, V](thrown: Throwable, record: ConsumerRecord[K, V])

[filosganga]

@PiotrFras Yep it is a very good idea! thanks