@Override
        public Producer<byte[], byte[]> apply() {
          return new KafkaProducer<>(new HashMap<String, Object>());
        }
Tests the instantiation of a KafkaSystemProducer from Java clients
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemProducerJava.java