Peter Roelants
05/03/2021, 8:24 AMclass GetKafkaConfig(prefect.Task):
    """
    Get Kafka configuration
    """
    def run(
                self,
                timeout: timedelta
            ) -> KafkaConfig:
        return KafkaConfig(
            broker_address=os.environ['KAFKA_BROKER_ADDRESS'],
            topic_name=os.environ['KAFKA_TOPIC_NAME'],
            timeout=timeout
        )https://docs.prefect.io/orchestration/tutorial/hello-flow-run-parameter-config.png▾
Kevin Kho
Peter Roelants
05/03/2021, 2:48 PMKevin Kho
Peter Roelants
05/03/2021, 3:10 PM