IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-01-11 00:12:04 -06:00
Code Issues Packages Projects Releases Wiki Activity

Log e2e latency at debugging levelˆ

Browse Source
This commit is contained in:
Massimiliano Mirelli 2023-02-23 14:35:48 +02:00
parent 675f1c99df
commit c516baaedd
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaConsumer.java
View File

@ -116,10 +116,11 @@ public class OpTimeTrackKafkaConsumer extends OpTimeTrackKafkaClient {
if (record != null) { if (record != null) {
if (logger.isDebugEnabled()) { if (logger.isDebugEnabled()) {
logger.debug( logger.debug(
"Receiving message is successful: [{}] - offset({}), cycle ({})", "Receiving message is successful: [{}] - offset({}), cycle ({}), e2e_latency_ms({})",
printRecvedMsg(record), printRecvedMsg(record),
record.offset(), record.offset(),
cycle); cycle,
System.currentTimeMillis() - record.timestamp());
} }
if (!autoCommitEnabled) { if (!autoCommitEnabled) {