Ler mensagens
Eu não dei uma olhada no tópico. Eu li o tópico.
Ler sem perturbar
No Kafka, o Marshall lê fazendo seek num offset. Ele nunca entra num grupo de consumo, nunca commita offset e nunca cria tópico só por perguntar dele (allow.auto.create.topics=false). Quem consome o tópico não tem como saber que ele passou por ali, então é seguro em produção.
Selecione um tópico e o Marshall lê as mensagens mais novas. Quantas fica em Ajustes › Mensagens por tópico (de 10 a 1.000, 100 por padrão).
De onde ler
- Ler mais carrega a próxima página, mais antiga.
- Ler a partir de um momento começa de outro lugar: O começo, As mais recentes ou Num momento no tempo…, que é um seek de verdade por timestamp (
offsets_for_times), não uma varredura. - Broker › Reler mensagens (⇧ ⌘ R) lê de novo a posição atual.
Os autos
Cada linha mostra onde a mensagem mora (p3·1204 é a partição 3, offset 1204), a chave e o payload. Selecione uma para abrir os autos: o payload formatado e destacado, os headers e os metadados. Copiar coloca na área de transferência.
Uma mensagem com chave e sem valor é uma tombstone: a chave foi apagada. O Marshall marca como tal, porque não é uma mensagem vazia.
Uma tombstone não é mensagem vazia. Morro nessa praia.
Achando uma mensagem
Buscar nestas mensagens procura na chave, no payload e nos headers do que já foi lido. Não busca no tópico inteiro, e não finge que busca: payloads binários e Avro que não deu para decodificar não são comparados como texto.
Quando não tem nada
Uma partição vazia diz Nada retido. O Kafka só guarda o que a retenção e a compactação deixam, então o que você vê é o que está retido agora, não tudo o que já foi produzido.