Christian Kosmowski
Christian Kosmowski
Okay thanks for the info. In my case the deserialization fails, it would have been good to have the record to move it to some other topic for later manual...
We stayed with the default which should be: https://github.com/micronaut-projects/micronaut-kafka/blob/master/kafka/src/main/java/io/micronaut/configuration/kafka/serde/JsonSerde.java I think the following could be a problem for us: https://github.com/micronaut-projects/micronaut-kafka/blob/67a8ea172bae75847e133988bb10696c6512d322/kafka/src/main/java/io/micronaut/configuration/kafka/serde/JsonSerde.java#L78-L83 so let me start over. Actually we'd like to use...
Our problem here is that the call to objectSerializer.deserialize(data, type) throws Exceptions different to Serialization Exception and that these Exceptions are not handled with the seekPastDeserializationError feature.
Yes that's correct. But there is IllegalArgumentException and/or DateTimeParseException for example when a String is beeing converted to a Date by the objectSerializer. And i think there can be more...
A global Exception catch and throwing a SerializationException would probably do the trick. Since if i am correct it would lead to the seekPastDeserializationError feature to do its workd and...
I don't think that my real problem is clear here. Please see https://github.com/micronaut-projects/micronaut-kafka/issues/110#issuecomment-603240398 The call to `objectSerializer.deserialize(data, type) ` can raise any exception type other than serializationException which breaks the...
Hi, please see https://github.com/micronaut-projects/micronaut-kafka/issues/110#issuecomment-613487454 the missing ConsumerRecord isn't the real problem for me here. It is the fact that Exceptions occuring in deserialize() are not catched and rethrown as SerializationExceptions.
What need to be done to get this into the project? I'd really like to see streams metrics as well.
I think what was meant by the opener of this ticket is. If you use `io.confluent.kafka.serializers.KafkaAvroSerializer` as the serializer configured for the producers, this serializer needs an instance of the...
If "PRs" is short for prayers i'll send you some. If you mean pull requests this feature might actually be a good one to start contributing. I'll do my very...