Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
Description
public void close() { List<String> connections = new ArrayList<>(channels.keySet()); try { for (String id : connections) close(id); // this line } finally {
KafkaChannel has a lot of releasable objects so we ought to try to close all channels.
Attachments
Issue Links
- links to