code: protected ProducerRecord<Object, Object> createKafkaMessage(Object pRequestString, Map<String, String> headers) {
          if (headers == null)
              recordProps = getRecordProps();
          else {
              recordProps = new Properties();
              recordProps.putAll(headers);
              String partition = (String)recordProps.get(RECORD_PARTITION);
              Integer partitionInt = new Integer(partition);
              recordProps.replace(RECORD_PARTITION, partitionInt);
          }
          return  new ProducerRecord<>((String)recordProps.get(KAFKA_TOPIC_NAME), (Integer)recordProps.get(RECORD_PARTITION), recordProps.get(RECORD_KEY), pRequestString);
      }
docs: /*
  Object should be based on what is set as KEY_SERIALIZER_CLASS_CONFIG, We are assuming value is of String type