seokjin0414 commented on code in PR #2781:
URL: https://github.com/apache/iggy/pull/2781#discussion_r2869076077
##########
core/connectors/runtime/src/sink.rs:
##########
@@ -377,6 +404,63 @@ fn init_sink(
}
}
+pub(crate) async fn setup_sink_consumers(
Review Comment:
Extracted common logic into shared functions:
- Sink: setup_sink_consumers() + spawn_consume_tasks() — both init() and
start_connector() now use these (7d95a1fe)
- Source: setup_source_producer() + spawn_source_handler() — both
init()/handle() and start_connector() now use these (274d03ad)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
