StructsΒ§
- Record π
- Record
Format π
EnumsΒ§
- Decoded
Value π - Format π
- Topic π
FunctionsΒ§
- decode_
avro π - Decode Avro
byteswithschema, stripping Glue framing whenglueis set and Confluent framing otherwise. - decode_
messages π - get_
topic π - parse_
expected_ πmessages - remaining π
- resolve_
glue_ πschemas - Resolve the writer schema for each record side from AWS Glue.
- run_
verify_ data - split_
headers π - Expect and split out
nwhitespace-delimited headers before the main contents of the βexpectβ row. - verification_
start_ πoffset - verify_
topic_ πexhausted - verify_
topics_ exhausted - Verifies that no records remain after each topicβs final exact verification.
- verify_
with_ πpartial_ search