[KAFKA-8501] Remove key and value from exception message

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.4.0
• Component/s: streams
• Labels: easy-fix newbie
• Assignee: Carlos Manuel Duclos Vergara
• Reporter: Badai Aqrandista
• Created: 06/Jun/19 22:58
• Updated: 15/May/20 02:33
• Resolved: 11/Jun/19 14:08

Description

KAFKA-7510 moves the WARN messages that contain key and value to TRACE level. But the exceptions still contain key and value. These are the two in RecordCollectorImpl:

 

https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java#L185-L196

 

https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java#L243-L254

 

Can these be modified as well to remove key and value from the error message, which we don't know what log level it will be printed in?

Issue Links

• fixes: KAFKA-6804 Event values should not be included in log messages
• links to: GitHub Pull Request #6904