From 322c22a4eb396347e8c521c0f8a54dd2b35cb37c Mon Sep 17 00:00:00 2001
From: Tim McCormack <tmccormack@edx.org>
Date: Thu, 1 Sep 2022 13:27:34 -0400
Subject: [PATCH] chore: Upgrade event-bus-kafka to 0.6.0 (#30934)

---
 cms/djangoapps/contentstore/signals/handlers.py | 6 +++---
 requirements/constraints.txt                    | 2 +-
 requirements/edx/base.txt                       | 2 +-
 requirements/edx/development.txt                | 2 +-
 requirements/edx/testing.txt                    | 2 +-
 5 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/cms/djangoapps/contentstore/signals/handlers.py b/cms/djangoapps/contentstore/signals/handlers.py
index 62efb60198..44bfdea329 100644
--- a/cms/djangoapps/contentstore/signals/handlers.py
+++ b/cms/djangoapps/contentstore/signals/handlers.py
@@ -11,7 +11,7 @@ from django.core.cache import cache
 from django.db import transaction
 from django.dispatch import receiver
 from edx_toggles.toggles import SettingToggle
-from edx_event_bus_kafka.publishing.event_producer import send_to_event_bus
+from edx_event_bus_kafka import get_producer
 from opaque_keys.edx.keys import CourseKey
 from openedx_events.content_authoring.data import CourseCatalogData, CourseScheduleData
 from openedx_events.content_authoring.signals import COURSE_CATALOG_INFO_CHANGED
@@ -156,9 +156,9 @@ def listen_for_course_catalog_info_changed(sender, signal, **kwargs):
     """
     Publish COURSE_CATALOG_INFO_CHANGED signals onto the event bus.
     """
-    send_to_event_bus(
+    get_producer().send(
         signal=COURSE_CATALOG_INFO_CHANGED, topic='course-catalog-info-changed',
-        event_key_field='catalog_info.course_key', event_data={'catalog_info': kwargs['catalog_info']}
+        event_key_field='catalog_info.course_key', event_data={'catalog_info': kwargs['catalog_info']},
     )
 
 
diff --git a/requirements/constraints.txt b/requirements/constraints.txt
index 1e30e8447e..debc4acf31 100644
--- a/requirements/constraints.txt
+++ b/requirements/constraints.txt
@@ -30,7 +30,7 @@ edx-enterprise==3.56.9
 # As of 2022-08-24, Arch-BOM (at 2U) is changing event-bus-kafka rapidly, with breaking changes.
 # As long as that is happening, Arch-BOM will manually bump this dependency to ensure
 # that any necessary code changes can happen in lockstep.
-edx-event-bus-kafka==0.4.3
+edx-event-bus-kafka==0.6.0
 
 # oauthlib>3.0.1 causes test failures ( also remove the django-oauth-toolkit constraint when this is fixed )
 oauthlib==3.0.1
diff --git a/requirements/edx/base.txt b/requirements/edx/base.txt
index 38541d310c..3b5c24a941 100644
--- a/requirements/edx/base.txt
+++ b/requirements/edx/base.txt
@@ -487,7 +487,7 @@ edx-enterprise==3.56.9
     #   -c requirements/edx/../constraints.txt
     #   -r requirements/edx/base.in
     #   learner-pathway-progress
-edx-event-bus-kafka==0.4.3
+edx-event-bus-kafka==0.6.0
     # via
     #   -c requirements/edx/../constraints.txt
     #   -r requirements/edx/base.in
diff --git a/requirements/edx/development.txt b/requirements/edx/development.txt
index a39856b8ab..3c695cb2e9 100644
--- a/requirements/edx/development.txt
+++ b/requirements/edx/development.txt
@@ -601,7 +601,7 @@ edx-enterprise==3.56.9
     #   -c requirements/edx/../constraints.txt
     #   -r requirements/edx/testing.txt
     #   learner-pathway-progress
-edx-event-bus-kafka==0.4.3
+edx-event-bus-kafka==0.6.0
     # via
     #   -c requirements/edx/../constraints.txt
     #   -r requirements/edx/testing.txt
diff --git a/requirements/edx/testing.txt b/requirements/edx/testing.txt
index bd378708d7..4552853694 100644
--- a/requirements/edx/testing.txt
+++ b/requirements/edx/testing.txt
@@ -580,7 +580,7 @@ edx-enterprise==3.56.9
     #   -c requirements/edx/../constraints.txt
     #   -r requirements/edx/base.txt
     #   learner-pathway-progress
-edx-event-bus-kafka==0.4.3
+edx-event-bus-kafka==0.6.0
     # via
     #   -c requirements/edx/../constraints.txt
     #   -r requirements/edx/base.txt