public static ObjectMapper getObjectMapper() {
    if (objectMapper == null) {
      objectMapper = createObjectMapper();
    }
    return objectMapper;
  }
Wraps a ObjectMapper for serializing and deserializing Drain Notification Messages.
samza-core/src/main/java/org/apache/samza/drain/DrainNotificationObjectMapper.java