Ii4'SSKJr SSKrSSKrSSKrSSKrSSKJr SSKJ r Sr Sr Sr SSK r SSKrSSKJr SrSSKrSSKrSSKr\"\R2"5S :H5rS rS rS rS rSSjrSr SSjr!Sr"Sr#\(a\r$O*\(a \RJr$O\(a \RLr$OSr$Sr'\(a \RPr)O \(a\'r)O\(a \RPr)OSr)Sr*Sr+Sr,Sr-g!\a Sr Nf=f!\a SrNf=f!\a SrNf=f!\a SrNf=f!\a SrNf=f!\a SrGNf=f))absolute_importN)six)range) iSNAPr Yrr bccccccBiiic URSS5 [R"U4SS0UD6$![a. URSS5 [R"U4SS0UD6s$f=f)N block_linkedF block_moder )poplz4compress TypeError)payloadkwargss 1/venv/lib/python3.13/site-packages/kafka/codec.py _lz4_compressrsg A JJ~t ,<<FeFvF F A JJ|T *<<@A@@ @ As*-5A%$A%PyPycg)NTrrhas_gzipr;s rc[SL$N)snappyrrr has_snappyr ?s  rc[SL$r)zstdrrrhas_zstdr#Cs t rc4[bg[bg[bgg)NTF)rlz4f lz4framedrrrhas_lz4r'Gs   rcU(dSn[R"5n[R"USUS9nUR U5 UR 5 UR 5$!UR 5 f=f)N w)fileobjmode compresslevel)ioBytesIOgzipGzipFilewriteclosegetvalue)rr-bufgzippers r gzip_encoder7Qs\  **,CmmCcOG g  <<>  s A''A9c[R"U5n[R"USS9nUR 5UR 5 $!UR 5 f=f)Nr)r+r,)r.r/r0r1readr3)rr5r6s r gzip_decoder;bsC **W CmmCc2G||~  s A Ac^^^ [5(d [S5eU(d[R"T5$[R "5n[ [[5H.upEUR[R"SU-U55 M0 [(aSm O[R(aSm OSm U UU4Sj[S[!T5T55H[n[R"U5n[!U5nUR[R"SU55 URU5 M] UR#5$) aEncodes the given data with snappy compression. If xerial_compatible is set then the stream is encoded in a fashion compatible with the xerial snappy library. The block size (xerial_blocksize) controls how frequent the blocking occurs 32k is the default in the xerial library. The format winds up being: +-------------+------------+--------------+------------+--------------+ | Header | Block1 len | Block1 data | Blockn len | Blockn data | +-------------+------------+--------------+------------+--------------+ | 16 bytes | BE int32 | snappy bytes | BE int32 | snappy bytes | +-------------+------------+--------------+------------+--------------+ It is important to note that the blocksize is the amount of uncompressed data presented to snappy at each block, whereas the blocklen is the number of bytes that will be present in the stream; so the length will always be <= blocksize. Snappy codec is not available!cXX!-$rrrisizes rsnappy_encode..s 7TV+[U5XU-R5$r) memoryviewtobytesr@s rrCrDs:g+>qa+H+P+P+Rrc38># UHnT"TUT5v M g7frr).0rAchunkerrxerial_blocksizes r snappy_encode..s&ECa'1&677Csr!i)r NotImplementedErrorrrr.r/zip_XERIAL_V1_FORMAT_XERIAL_V1_HEADERr2structpackPYPYrPY2rlenr4) rxerial_compatiblerMoutfmtdatchunkblock block_sizerLs ` ` @r snappy_encoderans4 <<!"ABB w'' **,C)+<= &++cCi-.> t= D SE CL2BCE&Z  &++dJ/0 % E <<>rc[U5S:aj[R"S[SS-[ U5SS5n[R"S[SS-[ U5SS5up#U[ SS:Xagg)aDetects if the data given might have been encoded with the blocking mode of the xerial snappy library. This mode writes a magic header of the format: +--------+--------------+------------+---------+--------+ | Marker | Magic String | Null / Pad | Version | Compat | +--------+--------------+------------+---------+--------+ | byte | c-string | byte | int32 | int32 | +--------+--------------+------------+---------+--------+ | -126 | 'SNAPPY' | | | | +--------+--------------+------------+---------+--------+ The pad appears to be to ensure that SNAPPY is a valid cstring The version is the version of this format as written by xerial, in the wild this is currently 1 as such we only support v1. Compat is there to claim the minimum supported version that can read a xerial block stream, presently in the wild this is 1. r>NTF)rYrUunpackrSbytesrT)rmagicversioncompats r_detect_xerial_streamrjs|, 7|b c$5bq$995>"1;MN --.?.C(CU7^TUVXEYZ %bq) ) rc[5(d [S5e[U5(a[R"5nUSSn[ U5nSnXC:aU[ R"SX$S5SnUS- nXE-nUR[R"X$U55 UnXC:aMUURS5 UR5$[R"U5$)Nr=rcrrP) r rQrjr.r/rYrU unpack_fromr2r decompressseekr:)rr[bytlengthcursorr`ends r snappy_decoderts <<!"ABBW%%jjlbclSo++D#g,?BJ aKF%C IIf''38 9F o  xxz  ))rc[R"5n[R"X5n[R"U5 USS:wa [ S5eUS$)zFDecode payload using interoperable LZ4 framing. Requires Kafka >= 0.10nextrz&lz4f unable to decompress full payloaddecomp)r%createDecompContextdecompressFramefreeDecompContext RuntimeError)rctxdatas r lz4f_decoder~sT  " " $C    -D3 F|qCDD >rcz[ce[U5nSnUSn[U[5(d [ U5nUS- S-nU(a'US-n[ U5nX1S'[ U5nXS-SnOXSn[R"USUS- 5R5SS nS RUSUS- UU/5$) zLEncode payload for 0.8/0.9 brokers -- requires an incorrect header checksum.Nrlr rdrr) xxhash lz4_encode isinstanceintord bytearrayrfxxh32digestjoin)rr} header_sizeflgcontent_size_bithcs rlz4_encode_old_kafkar s    g DK q'C c3  #hQ qQT{1}~&|$ d1[]+ , 3 3 5b >a$$&11'K_1``as#<;A:9A:r)Ti). __future__rr0r.platformrU kafka.vendorrkafka.vendor.six.movesrrTrSrr ImportError zstandardr" lz4.frameframerrr%r&rboolpython_implementationrWrr r#r'r7r;rarjrtr compressFramerr~rnrrrrrrrrrs&  (G " A H * * , 67" <~ F*2J ##J##JJ J J%%JJ>&.3 am  F  D" C  D I  FshC=D DD'D5E=DD DDD$#D$'D21D25E?EEE