Transmit kafka secret

nygrenh · nygrenh · commit 74b05ea8f30b · 2020-01-14T00:12:28.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
@@ -42,7 +42,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 })
+        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!
       puts "Batch publish finished for #{course.name}"

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ def run`
`42`	`42`	`progress: progress,`
`43`	`43`	`message_format_version: 1`
`44`	`44`	`}`
`45`		`- RestClient.post("#{@kafka_bridge_url}/api/v0/event", { topic: 'user_course_progress', payload: message }.to_json, { content_type: :json })`
	`45`	`+ 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`	`46`	`end`
`47`	`47`	`task.destroy!`
`48`	`48`	`puts "Batch publish finished for #{course.name}"`