code: protected void init() {
          Properties props = new Properties();
          props.put("bootstrap.servers", PropertyUtil.getProperty(PropertyUtil.HAWKULAR_APM_URI_PUBLISHER,
                  PropertyUtil.getProperty(PropertyUtil.HAWKULAR_APM_URI))
                  .substring(PropertyUtil.KAFKA_PREFIX.length()));
          props.put("acks", "all");
          props.put("retries", PropertyUtil.getPropertyAsInteger(PropertyUtil.HAWKULAR_APM_KAFKA_PRODUCER_RETRIES, 3));
          props.put("batch.size", 16384);
          props.put("linger.ms", 1);
          props.put("buffer.memory", 33554432);
          props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
          props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
  
          producer = new KafkaProducer<>(props);
      }
docs: This method initialises the publisher.