Module offset_commit_value 

Structs

OffsetCommitValue

Constants

FLEXIBLE_MIN

MAX_VERSION

MIN_VERSION

Functions

default_json

Default JSON payload matching Self::default() for JVM oracle differential testing. Only includes fields valid for the given version.

is_flexible

tagged_fixture

A message with a non-default value in every tagged field, at every depth, for the JVM oracle differential sweep. The value is the same at every version.

tagged_fixture_json

The JSON form of tagged_fixture() that Kafka’s JSON converter reads at version. It holds only the fields that the schema declares at that version.