Hi guys. I’m using committablePartitionedSource consumer. By default when one substream stops then its sibling substreams are stopped as well. Can I somehow have the rest of substreams continue their processing after one has stopped?
1 Like