Sebastien Viale created KAFKA-16811:
---
Summary: Punctuate Ratio metric almost impossible to track
Key: KAFKA-16811
URL: https://issues.apache.org/jira/browse/KAFKA-16811
Project: Kafka
Just as a reminder, here the link for the vote:
https://lists.apache.org/thread/o1kvv8zjzsp72ohcjpckdy544ko9tjjb
regards
Sébastien
De : Sebastien Viale
Envoyé : vendredi 3 mai 2024 10:35
À : dev@kafka.apache.org
Objet : [DISCUSS] KIP-1033: Add Kafka Streams
Hi,
So, we all agree to revert to the regular Headers interface in
ErrorHandlerContext.
We will update the KIP accordingly.
@Sophie => Yes, this is the last remaining question, and it has been open for
voting since last week.
Thanks
Sébastien
De : Andrew
Hi,
Thanks for your remarks
L1. I would say "who can do the most can do the least", even though most people
will fail and stop, we found it interesting to offer the possibility to
fail-and-send-to-DLQ
L2: We did not consider extending the TimestampExtractor because we estimate it
out of
Hello Nick,
Thanks for your remark.
5. The Record posted in the DLQ topic is not intended to be reprocessed by the
Kafka Streams application.
If users want to reprocess the records, it is up to them to take into
considerations the stream time and / or if the window has closed
regards
the
>>>> ProcessingContext interface since it already contains application ID
>> and
>>>> task ID and it would make the API for the handler cleaner.
>>>>
>>>>
>>>> 3.
>>>> Could you elaborate -- maybe with an example
Thanks for your review!
All the points make sense for us!
We updated the KIP for points 1 and 4.
2/ We followed the DeserializationExceptionHandler interface signature, it was
not on our mind that the record be forwarded with the ProcessorContext.
The ProcessingContext is sufficient,
