question: void pushDataMessage ( GTSEncoder encoder ) throws IOException { if ( null != encoder ) { KafkaDataMessage msg = new KafkaDataMessage ( ) ; msg . setType ( KafkaDataMessageType . STORE ) ; msg . setData ( encoder . getBytes ( ) ) ; msg . setClassId ( encoder . getClassId ( ) ) ; msg . setLabelsId ( encoder . getLabelsId ( ) ) ; sendDataMessage ( msg ) ; } else { sendDataMessage ( null ) ; } }
target:  Push a metadata message onto the buffered list of Kafka messages and flush the list to Kafka if it has reached a threshold.