При использовании Burrow для наблюдения за Кафкой
1) Что означают начальное и конечное смещение Burrow для данной группы потребителей в разделе темы? Я не смог найти никакой документации по этому поводу.
Что такое подходящая терминология Кафки? Терминология Kafka: Последнее зафиксированное смещение, Текущее смещение, Смещение отметки высокого уровня, Смещение конца бревна. На что указывает начало и конец смещения Burrow? Это смещение течения Кафки и смещения отметки Кафки Хайвотер?
Например,
http://localhost:8000/v2/kafka/local/consumer/MyGroup-1-4/lag
{
"error":false,
"message":"consumer group status returned",
"status":{
"cluster":"local",
"group":"MyGroup-1-4",
"status":"ERR",
"complete":false,
"partitions":[
{
"topic":"MyTopicTest-1",
"partition":1,
"status":"OK",
"start":{
"offset":28,
"timestamp":1468769616468,
"lag":0
},
"end":{
"offset":34,
"timestamp":1468805045000,
"lag":0
}
},
{
"topic":"MyTopicTest-1",
"partition":3,
"status":"STOP",
"start":{
"offset":32,
"timestamp":1468803763000,
"lag":0
},
"end":{
"offset":32,
"timestamp":1468804303000,
"lag":0
}
},
{
"topic":"MyTopicTest-1",
"partition":4,
"status":"OK",
"start":{
"offset":32,
"timestamp":1468804003000,
"lag":0
},
"end":{
"offset":33,
"timestamp":1468804783000,
"lag":0
}
},
{
"topic":"MyTopicTest-1",
"partition":5,
"status":"STOP",
"start":{
"offset":32,
"timestamp":1468803763000,
"lag":0
},
"end":{
"offset":32,
"timestamp":1468804303000,
"lag":0
}
},
{
"topic":"MyTopicTest-1",
"partition":6,
"status":"OK",
"start":{
"offset":33,
"timestamp":1468804423000,
"lag":0
},
"end":{
"offset":34,
"timestamp":1468805045000,
"lag":0
}
},
{
"topic":"MyTopicTest-1",
"partition":7,
"status":"OK",
"start":{
"offset":27,
"timestamp":1468769387995,
"lag":0
},
"end":{
"offset":33,
"timestamp":1468804783000,
"lag":0
}
},
{
"topic":"MyTopicTest-1",
"partition":9,
"status":"OK",
"start":{
"offset":27,
"timestamp":1468769433946,
"lag":0
},
"end":{
"offset":33,
"timestamp":1468804783000,
"lag":0
}
}
],
"partition_count":10,
"maxlag":null,
"totallag":0
},
"request":{
"url":"/v2/kafka/local/consumer/MyGroup-1-4/lag",
"host":"****",
"cluster":"local",
"group":"MyGroup-1-4",
"topic":""
}
}
2) Некоторые статусы помечены как ОСТАНОВЛЕННЫЕ. Правило закапывания для маркировки статуса как ОСТАНОВЛЕННОЕ: Если разница между текущим моментом и временем самого последнего смещения больше, чем разница между самым последним смещением и самым старым смещением в окне, потребитель находится в Состояние ОШИБКА, и раздел помечен как ОСТАНОВЛЕННЫЙ. Однако, если смещение потребителя и текущее смещение брокера для раздела равны, раздел не считается ошибочным.
Который час"? Это время, когда запрос задержки был отправлен в Burrow?
