Tension: instantiating it here raises the error. Outcome: await kafka_producer.start() # creates the consumer & starts it.

015b58d7-eadc-4156-897e-455c78415378