Condividi tramite


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

ConsumeRecord[]

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