Boyang Chen created KAFKA-9602: ---------------------------------- Summary: 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
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)