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