workspace(name = "kafka_source")