concurrency based on configuration

[github-actions]

olake/drivers/mongodb/internal/cdc.go

Lines 18 to 23 in 0b1fdb7

	// TODO: concurrency based on configuration
	return relec.Concurrent(context.TODO(), streams, len(streams), func(ctx context.Context, stream protocol.Stream, executionNumber int) error {
	return m.changeStreamSync(stream, pool)
	})
	}

---

This issue was generated by todo-issue based on a TODO comment in 0b1fdb7. It's been assigned to @hash-data because they committed the code.