This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from b74b182841a KAFKA-16786: Remove old assignment strategy usage in new
consumer (#16214)
add ebe1e964ffb KAFKA-16448: Add ProcessingExceptionHandler interface and
implementations (#16187)
No new revisions were added by this update.
Summary of changes:
.../ErrorHandlerContext.java} | 84 ++++++++++++--------
... LogAndContinueProcessingExceptionHandler.java} | 25 +++---
...a => LogAndFailProcessingExceptionHandler.java} | 27 +++----
...andler.java => ProcessingExceptionHandler.java} | 37 +++++----
.../internals/DefaultErrorHandlerContext.java | 90 ++++++++++++++++++++++
5 files changed, 187 insertions(+), 76 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/{processor/RecordContext.java =>
errors/ErrorHandlerContext.java} (63%)
copy
streams/src/main/java/org/apache/kafka/streams/errors/{LogAndContinueExceptionHandler.java
=> LogAndContinueProcessingExceptionHandler.java} (57%)
copy
streams/src/main/java/org/apache/kafka/streams/errors/{LogAndFailExceptionHandler.java
=> LogAndFailProcessingExceptionHandler.java} (58%)
copy
streams/src/main/java/org/apache/kafka/streams/errors/{StreamsUncaughtExceptionHandler.java
=> ProcessingExceptionHandler.java} (51%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/errors/internals/DefaultErrorHandlerContext.java
