Fixes an issue where the value of Kafka record sent to the FASTEN server logs and caused RecordTooLargeException.
@@ -301,7 +301,7 @@ public class FastenKafkaConsumer extends FastenKafkaConnection {
if(kafkaConsumer.recordProcessSuccessful()){
logToKafka(this.serverLog, this.serverLogTopic, new Date() + "| [" + this.consumerHostName + "] Plug-in " + kafkaConsumer.getClass().getSimpleName() +
- " processed successfully record [in " + timeFormatter.format((System.currentTimeMillis() - startTime) / 1000d) + " sec.]: " + r.value());
+ " processed successfully record [in " + timeFormatter.format((System.currentTimeMillis() - startTime) / 1000d) + " sec.]: " + r.key());
} else {
logToKafka(this.failedRecords, this.failedRecordsTopic, generateRecordStatus(kafkaConsumer.getClass().getSimpleName(),
r, this.kafkaConsumer.getPluginError()));
