create stream of byte array messages from kafka 0.9 concode_field_sep PlaceHolder placeHolder concode_field_sep ApexStream<String> fromFolder concode_elem_sep ApexStream<String> fromFolder concode_elem_sep ApexStream<T> fromInput concode_elem_sep ApexStream<String> fromKafka08 concode_elem_sep ApexStream<String> fromKafka08
ApexStream < byte [ ] > function ( String arg0 , String arg1 , Option ... arg2 ) { KafkaSinglePortInputOperator loc0 = new KafkaSinglePortInputOperator ( ) ; loc0 . setClusters ( arg0 ) ; loc0 . setTopics ( arg1 ) ; ApexStreamImpl < String > loc1 = new ApexStreamImpl < > ( ) ; return loc1 . addOperator ( loc0 , null , loc0 . outputPort , arg2 ) ; }