A data engineer has been tasked with consuming a stream of events from a Kafka topic named events_topic, which is hosted on a remote Kafka broker at host:port. Which of the following code snippets correctly establishes a streaming DataFrame in PySpark to read from this Kafka topic?