import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerializer;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.producer.KafkaProducer;
import io.confluent.kafka.streams.serdes.avro.SpecificAvroSerializer;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.producer.KafkaProducer;
{
Properties props = new Properties();
props.put("bootstrap.servers", properties.bootstrapServers);
{
Properties props = new Properties();
props.put("bootstrap.servers", properties.bootstrapServers);