from feldera.rest import FelderaClient
import os

BASE_URL = os.environ.get("FELDERA_BASE_URL", "http://localhost:8080")
KAFKA_SERVER = os.environ.get("FELDERA_KAFKA_SERVER", "localhost:19092")
PIPELINE_TO_KAFKA_SERVER = os.environ.get(
    "FELDERA_PIPELINE_TO_KAFKA_SERVER", "redpanda:9092"
)

TEST_CLIENT = FelderaClient(BASE_URL)