Compartilhar via

Consumer - Consume Topic In Partition With Offset

  • Referência
Serviço:
HDInsight Kafka REST Proxy
Versão da API:
v1

Consumir registros usando um consumidor simples
Consumir registros de uma partição de um tópico começando com um deslocamento específico. Por padrão, a contagem é 1. Ele pode ler no máximo 6 megabytes de dados ao mesmo tempo

GET https://clustername-kafkarest.azurehdinsight.net/v1/consumer/topics/{topic}/partitions/{partition}/offsets/{offset}
Com parâmetros opcionais: 
GET https://clustername-kafkarest.azurehdinsight.net/v1/consumer/topics/{topic}/partitions/{partition}/offsets/{offset}?count={count}

Parâmetros de URI

Nome Em Obrigatório Tipo Description
offset
 path True

integer (int64)

Deslocamento a partir do qual começar
partition
 path True

integer (int32)

ID de partição para consumir os registros de
topic
 path True

string

Tópico do qual consumir os registros
count
 query

integer (int32)

Número de registros a serem consumidos (opcional). Por padrão, a contagem é 1. Ele retorna a contagem de registros ou 6 megabytes de dados, que é menor.

Respostas

Nome Tipo Description
200 OK

ConsumeRecord[]

operação bem-sucedida
400 Bad Request

Solicitação incorreta
401 Unauthorized

Desautorizado
403 Forbidden

Proibido
404 Not Found

Não encontrado
500 Internal Server Error

Erro interno do servidor
Other Status Codes

Método não permitido

Definições

ConsumeRecord

Objeto

Lista de registros do consumidor

Nome Tipo Description
key

string

Chave para registro do consumidor
offset

integer (int64)

Deslocamento para registro do consumidor
partition

integer (int32)

ID de partição para registro do consumidor
timestamp

integer (int64)

Carimbo de data/hora para registro do consumidor
timestampType

string

Tipo de carimbo de data/hora para registro do consumidor, como tempo de acréscimo de log ou hora de criação
value

string

Valor do registro do consumidor