loicgreffier commented on code in PR #17475:
URL: https://github.com/apache/kafka/pull/17475#discussion_r1805467918
##########
streams/src/main/java/org/apache/kafka/streams/errors/internals/FailedProcessingException.java:
##########
@@ -24,13 +24,20 @@
*/
public class FailedProcessingException extends StreamsException {
private static final long serialVersionUID = 1L;
+ private final String failedProcessorNodeName;
- public FailedProcessingException(final String errorMessage, final
Exception exception) {
+ public FailedProcessingException(final String errorMessage, final String
failedProcessorNodeName, final Exception exception) {
super(errorMessage, exception);
+ this.failedProcessorNodeName = failedProcessorNodeName;
}
- public FailedProcessingException(final Exception exception) {
+ public FailedProcessingException(final String failedProcessorNodeName,
final Exception exception) {
// we need to explicitly set `message` to `null` here
super(null, exception);
+ this.failedProcessorNodeName = failedProcessorNodeName;
+ }
+
+ public String getFailedProcessorNodeName() {
Review Comment:
@cadonna Fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
