kw2542 commented on a change in pull request #1370:
URL: https://github.com/apache/samza/pull/1370#discussion_r434190953
##########
File path:
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala
##########
@@ -48,6 +48,23 @@ object CoordinatorStreamUtil extends Logging {
new MapConfig(coordinatorSystemConfig)
}
+ /**
+ * Creates coordinator stream from config.
+ *
+ * @param config to create coordinator stream.
+ */
+ def createCoordinatorStream(config: Config): Unit = {
+ val systemAdmins = new SystemAdmins(config)
+
+ // Create the coordinator stream if it doesn't exist
+ info("Creating coordinator stream")
Review comment:
Not really, this is the same logic I copy paste from the previous
CoordinatorStreamUtil#writeConfigToCoordinatorStream.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
