[
https://issues.apache.org/jira/browse/KAFKA-9602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044162#comment-17044162
]
ASF GitHub Bot commented on KAFKA-9602:
---------------------------------------
abbccdda commented on pull request #8166: (WIP) KAFKA-9602: Close the stream
producer only in EOS
URL: https://github.com/apache/kafka/pull/8166
This bug reproduces through the trunk stream test, the producer was closed
unexpectedly when EOS is not turned on.
Will work on adding unit test to guard this logic.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
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
> Incorrect close of producer instance during partition assignment
> ----------------------------------------------------------------
>
> Key: KAFKA-9602
> URL: https://issues.apache.org/jira/browse/KAFKA-9602
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 2.6.0
> Reporter: Boyang Chen
> Assignee: Boyang Chen
> Priority: Major
>
> The new StreamProducer instance close doesn't distinguish between an
> EOS/non-EOS shutdown. The StreamProducer should take care of that.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
