public static TestKafkaEvent fromString(String message) {
    String[] messageComponents = StringUtils.split(message, "|");
    return new TestKafkaEvent(messageComponents[0], messageComponents[1]);
  }
A Kafka event to use in testing only.
samza-test/src/test/java/org/apache/samza/test/util/TestKafkaEvent.java