WIP

edx_event_bus_kafka/__init__.py

@@ -2,18 +2,18 @@
 Kafka implementation for Open edX event bus.
 """
 
-from openedx_events.event_bus import EventBus
+from openedx_events.event_bus import EventProducer
 
 from edx_event_bus_kafka.consumer.event_consumer import consume_indefinitely
 from edx_event_bus_kafka.publishing.event_producer import send_to_event_bus
 
 __version__ = '0.4.1'
 
 
-class EventBusKafka(EventBus):
-    """Kafka implementation of the EventBus API."""
+class EventProducerKafka(EventProducer):
+    """Kafka implementation of the EventBus Producer API."""
 
-    def __init__(config):
+    def __init__():
         ...  # TODO Read config here and create producer and consumer?
 
     def send(
@@ -24,12 +24,11 @@ def send(
             signal=signal, topic=topic, event_key_field=event_key_field, event_data=event_data, sync=sync
         )
 
-    def consume_indefinitely(self, *, topic: str, group_id: str) -> NoReturn:
-        consume_indefinitely(topic=topic, group_id=group_id)
+class EventProducerKafka(EventProducer):
+    """Kafka implementation of the EventBus Producer API."""
 
+    def __init__():
+        ...  # TODO Read config here and create producer and consumer?
 
-def create(config) -> EventBusKafka:
-    """
-    Create the Kafka implementation of the EventBus API.
-    """
-    return EventBusKafka(config)
+    def consume_indefinitely(self, *, topic: str, group_id: str) -> NoReturn:
+        consume_indefinitely(topic=topic, group_id=group_id)