mynameborat commented on a change in pull request #1370:
URL: https://github.com/apache/samza/pull/1370#discussion_r434188774
##########
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:
then i'd prefer to remove this redundant logging. do you have anything
else in mind on why this is needed then?
----------------------------------------------------------------
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]
