← all corpora

kafka-protocol

reference corpus · status live · domain DB (Databases and storage engines) · lane A · refresh pinned · tags GLOBAL · MESSAGING · STANDARDS

What an agent uses it for

an agent implementing a Kafka client queries this for the protocol guide's exact request/response schemas and error codes

Use it
curl -fsSLO https://raw.githubusercontent.com/xerj-org/xerj/corpus-hub/tools/xerj-code/hub/kafka-protocol.json
xerj corpus add --from ./kafka-protocol.json
xerj corpus index kafka-protocol then xerj code kafka-protocol "your question"

Needs the xerj CLI and a local node running; the copy prompt covers both, checks each step, and shows how to stop only the node you started. No shell: the MCP tool xerj_code_search with corpus: "kafka-protocol", once the corpus is indexed on the node.

Sources and pins

sourcepinlicencesizereview note
corpus-kafka-docs 94ac9e02b712Apache-2.0 3.0 MB / 143 files Mirror of apache/kafka-site scoped to CURRENT docs only: content/en/43 + current root docs (143 files); static/ (~750MB vendored javadoc) and 40 old doc-version dirs dropped: the round-1 Q2 miss retrieved upgrade.md from three old versions ahead of the answer (version clones dilute like locale forks). LICENSE verbatim Apache-2.0. G7 round-2 2026-10-05: 3/5 pass 3/5 relevant PASS graded against eng

3.0 MB across 143 files. Added 2026-10-04.

People behind this corpus

Upstream authors (1)

Owners of the pinned repositories, credited under each repository's licence. They have not signed up here; their pages are attribution.

xerj-org@xerj-org · upstream

All contributors.

Rights

Apache-2.0. Redistribution permitted with attribution per the licence review. The review block records a human opening each licence file at the pin. Detector output is a hint, never the verdict.

Retrieval spot-check (G7)

3.0/5 relevant. Graded .

Q: Does Kafka guarantee that requests sent over a single TCP connection are processed in order?
expect:
top-5: corpus-kafka-docs/43/design/protocol.md / corpus-kafka-docs/43/design/protocol.md / corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/getting-started/introduction.md
grade: pass
Q: How is a null value encoded for a NULLABLE_STRING field in the Kafka wire protocol?
expect:
top-5: corpus-kafka-docs/43/implementation/message-format.md / corpus-kafka-docs/43/kafka-connect/user-guide.md / corpus-kafka-docs/43/design/protocol.md / corpus-kafka-docs/43/design/protocol.md / corpus-kafka-docs/43/kafka-connect/user-guide.md
grade: miss
Q: What are the allowed values for acks in a Kafka produce request?
expect:
top-5: corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/design/protocol.md / corpus-kafka-docs/43/security/encryption-and-authentication-using-ssl.md / corpus-kafka-docs/43/design/protocol.md
grade: miss
Q: Should consumer applications receive Kafka control records?
expect:
top-5: corpus-kafka-docs/43/streams/developer-guide/memory-mgmt.md / corpus-kafka-docs/43/implementation/message-format.md / corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/streams/core-concepts.md
grade: pass
Q: If all replicas of a Kafka partition are lost and only a stale replica recovers, can it take over as leader?
expect:
top-5: corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/design/design.md / corpus-kafka-docs/43/operations/basic-kafka-operations.md / corpus-kafka-docs/43/operations/eligible-leader-replicas.md / corpus-kafka-docs/43/operations/basic-kafka-operations.md
grade: pass

Agent score

From structured reviews that AI agents send after they use this corpus: through xerj hub pull, MCP queries, or the xerj_corpus_feedback tool. Each review rates usefulness 1–5, whether the answer was found, and freshness. This is not the human hub star count shown above. The two are never mixed.

Loading agent reviews…

Score = Bayesian mean of usefulness (prior 3.0 with weight 5), so a few reviews cannot swing it. One voice per installation per corpus per week; abnormal-volume reviewers are dropped. Coverage gaps appear only once 3 or more agents report the same one. How it works.

Traffic

Traffic stats load from /api/hub-traffic when this page runs JavaScript.

Views: visits to this page (search-engine crawlers excluded). Unique: distinct visitors per day, by a hash salted with the day, so the 14-day unique figure adds up daily uniques. Pulls: growth of the GitHub release download count of this corpus’s pack (xerj hub pull downloads from there; includes our own pack-verification downloads). Searches: hosted-hub queries for this corpus. Referring sites appear after 3 views. What is collected.

Agent usage

Usage stats load from /api/hub-usage when this page runs JavaScript.

Counted: requests agents send to the hosted hub API (hub.xerj.org/api/v1/code, /def) for this corpus. Queries on your own node (xerj code, xerj ask with a local pack, the MCP tools) never leave your machine and are not counted. Templates replace identifiers, versions, paths, numbers and quoted text with placeholders; one is shown only once it has been seen 3 times in 30 days, and any word asked fewer than 3 times shows as <term>. Raw queries are never published. What is collected.