@Override
        public Object apply() {
          return System.currentTimeMillis();
        }
Tests the instantiation of a KafkaSystemProducer from Java clients
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemProducerJava.java