Skip to content
GitLab
Unverified Commit 17cf8317 authored by Anil Gupta's avatar Anil Gupta Committed by GitHub
Browse files

Issue #KN-439 merge: Merge pull request #652 from Jayaprakash8887/release-5.2.0 

Issue #KN-439 feat: CSP migration
parents c2b14ec8 b15133c3
release-5.2.0 release-5.2.0_RC5
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 1 addition and 0 deletions
+1 -0
csp-migrator/src/main/scala/org/sunbird/job/cspmigrator/task/CSPMigratorStreamTask.scala
+ 1
− 0
View file @ 17cf8317
......@@ -36,6 +36,7 @@ class CSPMigratorStreamTask(config: CSPMigratorConfig, kafkaConnector: FlinkKafk
processStreamTask.getSideOutput(config.failedEventOutTag).addSink(kafkaConnector.kafkaStringSink(config.kafkaFailedTopic))
processStreamTask.getSideOutput(config.generateVideoStreamingOutTag).addSink(kafkaConnector.kafkaStringSink(config.liveVideoStreamingTopic))
processStreamTask.getSideOutput(config.liveContentNodePublishEventOutTag).addSink(kafkaConnector.kafkaStringSink(config.liveContentNodeRepublishTopic))
processStreamTask.getSideOutput(config.liveQuestionNodePublishEventOutTag).addSink(kafkaConnector.kafkaStringSink(config.liveQuestionNodeRepublishTopic))
cassandraStream.getSideOutput(config.liveCollectionNodePublishEventOutTag).addSink(kafkaConnector.kafkaStringSink(config.liveContentNodeRepublishTopic))
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment