text: CREATE DATABASE IF NOT EXISTS ${DB};
  USE ${DB};
  
  DROP TABLE IF EXISTS kafka_web_returns;
  CREATE TABLE kafka_web_returns
  USING kafka
  OPTIONS (
  kafka.bootstrap.servers = "${BOOTSTRAP_SERVERS}",
  subscribe = 'webreturns',
  output.mode = 'append',
  kafka.schema.registry.url = "${SCHEMA_REGISTRY_URL}",
  kafka.schema.record.name = 'WebReturns',
  kafka.schema.record.namespace = 'org.apache.spark.emr.baseline.testing',
  kafka.auto.register.schemas = 'true');
  