Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
1.5.0
-
None
Description
for (StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> streamRecordWriter : streamRecordWriters) { try { streamRecordWriter.broadcastEvent(message);
The BufferConsumer returned by broadcastEvent() should be closed.
Attachments
Issue Links
- links to