Guozhang Wang created KAFKA-4830: ------------------------------------ Summary: Augment KStream.print() to allow users pass in extra parameters in the printed string Key: KAFKA-4830 URL: https://issues.apache.org/jira/browse/KAFKA-4830 Project: Kafka Issue Type: Bug Components: streams Reporter: Guozhang Wang
Today {{KStream.print}} use the hard-coded result string as: {code} "[" + this.streamName + "]: " + keyToPrint + " , " + valueToPrint {code} And some users are asking to augment this so that they can customize the output string as {{KStream.print(KeyValueMapper<K, V, String>): {code} "[" + this.streamName + "]: " + mapper.apply(keyToPrint, valueToPrint) {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)