def get(): Properties = {
  val config = new Properties();
  config.put("client.id", InetAddress.getLocalHost().getHostName());
  config.put("bootstrap.servers", "YOUR_BOOT_STRAP_SERVER:9092");
  config.put("acks", "all");
  config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer]);
  config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, classOf[io.confluent.kafka.serial
  config.put("schema.registry.url", "YOUR_SCHEMA_REGISTRY:8081");


  config.put("max.request.size", "15728640")
  config
}