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);
    }
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
Publish to a kafka topic based on the connection information