9hSSKJr SSKJr SSKJrJrJrJr SSK J r /SQr "SS\5r "SS \5r "S S \5r"S S \5r"SS\5r\"S5r\"S5r\"SS\\\455r"SS\5rg))Sequence) dataclass)Generic NamedTupleOptionalTypeVar) KafkaError)OffsetAndMetadataTopicPartitionRecordMetadataConsumerRecordBrokerMetadataPartitionMetadatac0\rSrSr%Sr\\S'\\S'Srg)r zA topic and partition tupletopic partitionN) __name__ __module__ __qualname____firstlineno____doc__str__annotations__int__static_attributes__rUC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/structs.pyr r s% JNrr cN\rSrSr%Sr\\S'\\S'\\S'\\\S'Sr g) rz+A Kafka broker metadata used by admin toolsnodeIdhostportrackrN) rrrrrrrrrrrrrrrs,5 K I I 3-rrcr\rSrSr%Sr\\S'\\S'\\S'\\\S'\\\S'\ \ \S'S r g ) r.zGA topic partition metadata describing the state in the MetadataResponserrleaderreplicasisrerrorrN) rrrrrrrrlistrr rrrrrr.sDQ J>N6 K?3iC cNK J Qrrc0\rSrSr%Sr\\S'\\S'Srg)r CaThe Kafka offset commit API The Kafka offset commit API allows users to provide additional metadata (in the form of a string) when an offset is committed. This can be useful (for example) to store information about which node made the commit, what time the commit was made, etc. offsetmetadatarN) rrrrrrrrrrrrr r Cs K Mrr cx\rSrSr%Sr\\S'\\S'\\S'\\S'\ \\S'\\S'\ \\S 'S r g ) r Uz;Returned when a :class:`~.AIOKafkaProducer` sends a messagerrtopic_partitionr/ timestamptimestamp_typelog_start_offsetrN) rrrrrrrrr rrrrrr r UsQE JN## K }1sm#rr KTVTc\rSrSr%\\S'\\S'\\S'\\S'\\S'\\\S'\\ \S'\\\S '\\S '\\S '\ \ \\ 4\S 'S r g)r |rrr/r4r5keyvaluechecksumserialized_key_sizeserialized_value_sizeheadersrN)rrrrrrrrr7r8rtuplebytesrrrrr r |s{ J,N6 KGN"' "0 B<sm<> eCJ' ((rr c0\rSrSr%\\S'\\\S'Srg)OffsetAndTimestampr/r4rN)rrrrrrrrrrrrDrDs K}rrDN)collections.abcr dataclassesrtypingrrrraiokafka.errorsr __all__r rrr r r7r8r rDrrrrKs$!99& ZZ&R R*  $ Z F T] T]  WRV_   Fr