chore: Upgrade event-bus-kafka to 0.6.0 (#30934)

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']},
     )
 
 

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

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

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

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