root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 7 Packages Projects Releases Wiki Activity

MINOR: Fix warn logging in RecordCollectorImpl 

Fix warn log message in RecordCollectorImpl so it prints the exception message rather than `{}`

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Matthias J. Sax <matthias@confluent.io>, Bill Bejeck <bill@confluent.io>, GuozhangWang <wangguoz@gmail.com>

Closes #4318 from dguy/minor-logging-record-collector
This commit is contained in:
Damian Guy 2017-12-12 19:13:39 -08:00 committed by Guozhang Wang
parent b088822134
commit fe3699ce33
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
View File

@ -107,7 +107,7 @@ public class RecordCollectorImpl implements RecordCollector {
} else { } else {
if (sendException == null) { if (sendException == null) {
if (exception instanceof ProducerFencedException) { if (exception instanceof ProducerFencedException) {
log.warn(LOG_MESSAGE, key, value, timestamp, topic, exception); log.warn(LOG_MESSAGE, key, value, timestamp, topic, exception.getMessage());
sendException = new ProducerFencedException( sendException = new ProducerFencedException(
String.format(EXCEPTION_MESSAGE, String.format(EXCEPTION_MESSAGE,
logPrefix, logPrefix,