[
https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017673#comment-17017673
]
ASF GitHub Bot commented on KAFKA-9441:
---------------------------------------
mjsax commented on pull request #7977: KAFKA-9441: Refactor Kafka Streams
commit logic
URL: https://github.com/apache/kafka/pull/7977
- part of KIP-447
- create to producer per thread if eos-beta enabled
- commit all tasks at once if eos-beta enabled
Call for review @abbccdda @guozhangwang
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Refactor commit logic
> ---------------------
>
> Key: KAFKA-9441
> URL: https://issues.apache.org/jira/browse/KAFKA-9441
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Matthias J. Sax
> Assignee: Matthias J. Sax
> Priority: Major
>
> Using producer per thread in combination with EOS, it's not possible any
> longer to commit individual task independently (as done currently).
> We need to refactor StreamsThread, to commit all tasks at the same time for
> the new model.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
