Consumer - Consume Topic In Partition With Offset

Servizio:

HDInsight Kafka REST Proxy

Versione API:

v1

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}

Con parametri facoltativi:

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

Object

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