code: @Override
  	public void addEvent(Event event) {
  		ensureInitialized();
  		
  		KeyValuePair keyValuePair = new KeyValuePair(KafkaConstants.EVENT_TYPE, gson.toJson(event));
  		String message = gson.toJson(keyValuePair);
  		
  		try {
  			kafkaSender.send(Arrays.asList(APPSENSOR_ADD_EVENT_TOPIC), message);
  		} catch (InterruptedException | ExecutionException e) {
  			logger.error("Failed to send add event message to output topic.", e);
  		}
  	}
docs: {@inheritDoc}