Configure Producer to connect to Confluence

producerConfig.scala

import org.apache.kafka.clients.producer.KafkaProducer
import org.apache.kafka.streams.{StreamBuilder, StreamsConfig}
import java.util.Properties


val config: Properties = {
  val p = new Properties()
     p.put(StreamsConfig.APPLICATION_ID_CONFIG, "simple-confluent-stream")
    p.put(StreamsConfig.CLIENT_ID_CONFIG, "simple-confluent-stream-client")
    p.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092") 
    p.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    p.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")
    p
  }



//You can make use of the config in creating a stream as shown
val streams = new KafkaProducer[String, String](config)