hi team,
I have been working with metricbeat module and trying to get SUM (offset.newest)of topic by getting max from each partition. Seems like i just cannot get right SUM. here is the structure
"kafka": {
"partition": {
"broker": {
"id": 1,
"address": "localhost:9092"
},
"partition": {
"replica": 1,
"insync_replica": true,
"id": 2,
"leader": 1
},
"offset": {
"newest": 2380344,
"oldest": 0
},
"topic": {
"name": "ABC.20181115"
}
}
}