mjsax commented on code in PR #14864:
URL: https://github.com/apache/kafka/pull/14864#discussion_r1413296164
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java:
##########
@@ -136,8 +135,8 @@ StreamsProducer streamsProducerForTask(final TaskId taskId)
{
}
StreamsProducer threadProducer() {
- if (processingMode != EXACTLY_ONCE_V2) {
- throw new IllegalStateException("Expected EXACTLY_ONCE_V2 to be
enabled, but the processing mode was " + processingMode);
+ if (processingMode == EXACTLY_ONCE_ALPHA) {
Review Comment:
Yes. When this code was added, there was no reason to call this method for
ALOS and to get the producer out -- only for EOSv2 it was required for error
handling. Thus, the check was very restrictive.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
