Merge branch 'kafka' of https://github.com/cedadev/stac-generator int…

…o kafka

Conflicts:
	stac_generator/plugins/outputs/kafka.py

stac_generator/plugins/outputs/kafka.py

@@ -60,18 +60,6 @@ def __init__(self, **kwargs):
             self.key_term = "uri"
         self.producer = Producer(self.config)
 
-    def delivery_callback(err, msg):
-        if err:
-            print("ERROR: Message failed delivery: {}".format(err))
-        else:
-            print(
-                "Produced event to topic {topic}: key = {key:12} value = {value:12}".format(
-                    topic=msg.topic(),
-                    key=msg.key().decode("utf-8"),
-                    value=msg.value().decode("utf-8"),
-                )
-            )
-
     def export(self, data: dict, **kwargs) -> None:
         """
         Post the message to the kafka server.
@@ -82,5 +70,4 @@ def export(self, data: dict, **kwargs) -> None:
         key = data.get(self.key_term, None)
         message = json.dumps(data).encode("utf8")
         self.producer.produce(self.topic, key=key, value=message)
-
         self.producer.flush()