Closed ghost closed 5 years ago
When the input port of the MessageHubConsumer receives a final marker, the runtime closes the output port. The consumer operator keeps consuming, but does not submit any tuple to the output port.
No technical solution possible, only documentation of this restriction. See https://github.com/IBMStreams/streamsx.kafka/issues/146#issuecomment-463197960.
SPLDoc improved in v1.8.0
When the input port of the MessageHubConsumer receives a final marker, the runtime closes the output port. The consumer operator keeps consuming, but does not submit any tuple to the output port.