Consumer - Consume Topic In Partition With Offset
Utilizzare i record usando un consumer semplice
Utilizzare record da una partizione di un argomento che inizia con un offset specifico. Per impostazione predefinita, il numero è 1. Può leggere un massimo di 6 megabyte di dati contemporaneamente
GET https://clustername-kafkarest.azurehdinsight.net/v1/consumer/topics/{topic}/partitions/{partition}/offsets/{offset}
GET https://clustername-kafkarest.azurehdinsight.net/v1/consumer/topics/{topic}/partitions/{partition}/offsets/{offset}?count={count}
Parametri dell'URI
Nome | In | Necessario | Tipo | Descrizione |
---|---|---|---|---|
offset
|
path | True |
integer (int64) |
Offset da cui iniziare |
partition
|
path | True |
integer (int32) |
ID partizione da cui utilizzare i record |
topic
|
path | True |
string |
Argomento da cui utilizzare i record |
count
|
query |
integer (int32) |
Numero di record da utilizzare (facoltativo). Per impostazione predefinita, il numero è 1. Restituisce il numero di record o 6 megabyte di dati, che è più piccolo. |
Risposte
Nome | Tipo | Descrizione |
---|---|---|
200 OK |
operazione riuscita |
|
400 Bad Request |
Richiesta non valida |
|
401 Unauthorized |
Non autorizzata |
|
403 Forbidden |
Vietato |
|
404 Not Found |
Non trovato |
|
500 Internal Server Error |
Errore Interno del Server |
|
Other Status Codes |
Metodo non consentito |
Definizioni
ConsumeRecord
Elenco di record consumer
Nome | Tipo | Descrizione |
---|---|---|
key |
string |
Chiave per il record consumer |
offset |
integer (int64) |
Offset per il record consumer |
partition |
integer (int32) |
ID partizione per il record consumer |
timestamp |
integer (int64) |
Timestamp per il record consumer |
timestampType |
string |
Tipo di timestamp per il record consumer, ad esempio l'ora di accodamento del log o l'ora di creazione |
value |
string |
Valore per il record consumer |