Correct topic name

nygrenh · nygrenh · commit 5e20c5769d38 · 2020-01-14T02:01:39.000+02:00
diff --git a/app/background_tasks/kafka_batch_update_points_task.rb b/app/background_tasks/kafka_batch_update_points_task.rb
@@ -43,7 +43,7 @@ def run
           progress: progress,
           message_format_version: 1
         }
-        RestClient.post("#{@kafka_bridge_url}/api/v0/event", { topic: 'user_course_progress', payload: message }.to_json, { content_type: :json, authorization: "Basic #{@kafka_bridge_secret}" })
+        RestClient.post("#{@kafka_bridge_url}/api/v0/event", { topic: 'user-course-progress', payload: message }.to_json, { content_type: :json, authorization: "Basic #{@kafka_bridge_secret}" })
       end
       task.destroy!
       Rails.logger.info "Batch publish finished for #{course.name}"

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ def run`
`43`	`43`	`progress: progress,`
`44`	`44`	`message_format_version: 1`
`45`	`45`	`}`
`46`		`- RestClient.post("#{@kafka_bridge_url}/api/v0/event", { topic: 'user_course_progress', payload: message }.to_json, { content_type: :json, authorization: "Basic #{@kafka_bridge_secret}" })`
	`46`	`+ RestClient.post("#{@kafka_bridge_url}/api/v0/event", { topic: 'user-course-progress', payload: message }.to_json, { content_type: :json, authorization: "Basic #{@kafka_bridge_secret}" })`
`47`	`47`	`end`
`48`	`48`	`task.destroy!`
`49`	`49`	`Rails.logger.info "Batch publish finished for #{course.name}"`