nd4j-serde/nd4j-camel-routes/nd4j-kafka/src/main/java/org/nd4j/camel/kafka/Nd4jKafkaProducer.java
public void publish(INDArray arr) {
        if (producerTemplate == null)
            producerTemplate = camelContext.createProducerTemplate();
        producerTemplate.sendBody("direct:start", arr);
    }
public void publish(INDArray arr) {
        if (producerTemplate == null)
            producerTemplate = camelContext.createProducerTemplate();
        producerTemplate.sendBody("direct:start", arr);
    }
Publish to a kafka topic
based on the connection information
@param arr