mostafa / xk6-kafka / 25072154492

79%

Build Type

push

github

Committed by web-flow

Commit Message

Add v2 protobuf serde support and docs (#389)

* feat(kafka): add dynamic protobuf serde runtime for v2

Implement SCHEMA_TYPE_PROTOBUF support across serialize/deserialize using protobuf v2 reflection and dynamic messages, including object/bytes modes, message index framing, and protobuf-specific metadata fields for schema resolution.

* test(kafka): add protobuf serde coverage for v2 flows

Cover protobuf object and bytes mode round-trips, standalone dependency resolution, and protobuf subject naming behavior to lock in the new serde runtime behavior.

* docs(v2): add protobuf example and sync generated API docs

Document protobuf support in supported features, add a schema-registry protobuf script, and regenerate v2 API docs/declarations to reflect new Schema and Container protobuf fields.

* Prettier

* style(kafka): resolve protobuf lint and formatting issues

Apply golangci-lint-driven cleanups in protobuf serde and related schema files, including modernized loops/maps usage and gofmt formatting for a clean lint pass.

* test(kafka): raise coverage for protobuf serde paths

Add focused protobuf and deserialize branch tests to recover package coverage after v2 protobuf serde support, including runtime error paths and schema-less decode flows.

* fix(kafka): accept plain string payloads in compat produce

Decode producer message key/value strings as raw bytes in the compatibility path instead of JSON base64 semantics, and cover it in compatibility tests to keep v2 smoke scripts passing.

Coverage Stats

357 of 471 new or added lines in 4 files covered. (75.8%)

4 existing lines in 2 files now uncovered.

3619 of 4544 relevant lines covered (79.64%)

30.39 hits per line