Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
3.3.0
-
None
-
None
Description
The new `close(CloseOptions)` function has a few bugs. (https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java#L1518-L1561)
Notably, it needs to remove CGs per StreamThread.
Attachments
Issue Links
- is caused by
-
KAFKA-13217 Reconsider skipping the LeaveGroup on close() or add an overload that does so
- Resolved
- links to