ByTopicRecordTranslator < K , V > function ( String arg0 , Func < ConsumerRecord < K , V > , List < Object >> arg1 , Fields arg2 , String arg3 ) { return forTopic ( arg0 , new SimpleRecordTranslator < > ( arg1 , arg2 , arg3 ) ) ; }
configure a translator for a given topic . concode_field_sep Map<String,Fields> streamToFields concode_elem_sep Map<String,RecordTranslator<K,V>> topicToTranslator concode_elem_sep long serialVersionUID concode_elem_sep RecordTranslator<K,V> defaultTranslator concode_field_sep void cacheNCheckFields concode_elem_sep List<Object> apply concode_elem_sep List<String> streams concode_elem_sep Fields getFieldsFor