class_docstr: Kafka event broker.
class_docstr_tok: ["Kafka","event","broker","."]
docstr: Get value of the `RASA_ENVIRONMENT` environment variable.
docstr_tok: ["Get","value","of","the","`","RASA_ENVIRONMENT","`","environment","variable","."]
code: def rasa_environment(self) -> Optional[Text]:
      """Get value of the `RASA_ENVIRONMENT` environment variable."""
      return os.environ.get(
          "RASA_ENVIRONMENT", "RASA_ENVIRONMENT_NOT_SET"
      )
  
imports: import asyncio
  import os
  import json
  import logging
  import structlog
  import threading
  from asyncio import AbstractEventLoop
  from typing import Any, Text, List, Optional, Union, Dict, TYPE_CHECKING
  import time
  from rasa.core.brokers.broker import EventBroker
  from rasa.core.exceptions import KafkaProducerInitializationError
  from rasa.shared.utils.io import DEFAULT_ENCODING
  from rasa.utils.endpoints import EndpointConfig
  import rasa.shared.utils.common
label_desc: Use image node_id 8 for calling the KafkaEventBroker obj's underlying member method code with example usage: obj.rasa_environment() and returns: os