Puts a record key instead of value in plug-ins' errors, to avoid big Kafka records.
@@ -147,7 +147,7 @@ public class FastenKafkaConsumer extends FastenKafkaConnection {
// .put("partition", String.valueOf(record.partition())).put("offset", String.valueOf(record.offset())).put("record",
// record.value()).put("status", status).toString();
- return new JSONObject(record.value()).put("error", status).toString();
+ return new JSONObject(record.key()).put("error", status).toString();
}
/**
