[GitHub] [kafka] ableegoldman commented on a change in pull request #11787: KAFKA-12738: tracking task errors

ableegoldman commented on a change in pull request #11787: URL: https://github.com/apache/kafka/pull/11787#discussion_r813725686 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java ## @@ -0,0 +1,98 @@ +/* + * Licensed to

[GitHub] [kafka] ableegoldman commented on a change in pull request #11787: KAFKA-12738: tracking task errors

ableegoldman commented on a change in pull request #11787: URL: https://github.com/apache/kafka/pull/11787#discussion_r813714182 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/ErrorHandlingIntegrationTest.java ## @@ -0,0 +1,165 @@ +/* + * Licensed to

[GitHub] [kafka] ableegoldman commented on a change in pull request #11787: KAFKA-12738: tracking task errors

ableegoldman commented on a change in pull request #11787: URL: https://github.com/apache/kafka/pull/11787#discussion_r812575798 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java ## @@ -0,0 +1,144 @@ +/* + * Licensed

[GitHub] [kafka] ableegoldman commented on a change in pull request #11787: KAFKA-12738: tracking task errors

ableegoldman commented on a change in pull request #11787: URL: https://github.com/apache/kafka/pull/11787#discussion_r812573407 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java ## @@ -63,8 +68,21 @@ public TaskExecutor(final

[GitHub] [kafka] ableegoldman commented on a change in pull request #11787: KAFKA-12738: tracking task errors

ableegoldman commented on a change in pull request #11787: URL: https://github.com/apache/kafka/pull/11787#discussion_r811811601 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java ## @@ -0,0 +1,144 @@ +/* + * Licensed