
    9h              
          S SK r S SKrS SKJrJr  S SKJr   " S S\5      r\S:X  Ga+  \ R                  " SS9r
\
R                  S	\S
S9  \
R                  S\S S9  \
R                  SSS
S9  \
R                  SSS9  \
R                  S\SSS9  \
R                  SS\SS9  \
R                  S\SSS9  \
R                  S\SS S9  \
R                  S\S S S9  \
R                  S!S"S9  \
R                  S#S$S%S&S'/ S(9  \" \
R                  5       5      rS)S
S*.r\R%                  S"S5      b$  \R'                  \R(                  " \S"   5      5        \R'                  \R%                  S%/ 5       V s/ s H  o S    R+                  S+5      PM     sn 5        \R,                  " \\5        \" \5      r\S   \l        \S,   r\S-   r\S   b	  \S   S.-   rOS/r\S    rS r\S :  a  S0\-  rOS r\R?                  S1\R0                  \4-  5         \ " S \R0                  5       H  r!\RD                  (       d    O\R                  " 5       \-   r#\RD                  (       a\  \S :w  a  S/\-  r$\S$-   \-  rOSr$ \RJ                  RM                  \\\!-  \$\R%                  SS 5      S29  \=RN                  S$-  sl'          \-" S \#\R                  " 5       -
  5      r.\RJ                  RY                  \.S69  \.S7::  a  M  M>      \R?                  S85         \RJ                  Ra                  S95        \Rc                  S:\2" \RJ                  5      S;.5        \R?                  S<5        ggs  sn f ! \ aF  r(\RS                  S3\!\R0                  \" \(5      4-  5        \=RT                  S$-  sl*         Sr(C(NSr(C(f\+ a>    \R?                  S4\!\R0                  4-  5        \RJ                  RY                  S5S69   GM  f = f! \/ a     GNf = f! \/ a     Nf = f)=    N)ProducerKafkaException)VerifiableClientc                   2   ^  \ rS rSrSrU 4S jrS rSrU =r$ )VerifiableProducer   zf
confluent-kafka-python backed VerifiableProducer class for use with
Kafka's kafkatests client tests.
c                    > [         [        U ]  U5        U R                  U R                  S'   [        S0 U R                  D6U l        SU l        SU l        SU l	        g)z<
conf is a config dict passed to confluent_kafka.Producer()
on_deliveryr   N )
superr   __init__dr_cbconfr   producer	num_ackednum_sentnum_err)selfr   	__class__s     rC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/kafkatest/verifiable_producer.pyr   VerifiableProducer.__init__   sO     	 $06#'::		-  -499-    c           	         U(       a`  U =R                   S-  sl         U R                  S[        U5      UR                  5       UR	                  5       UR                  5       S.5        gU =R                  S-  sl        U R                  SUR                  5       UR                  5       UR                  5       UR	                  5       UR                  5       S.5        g)z9Per-message Delivery report callback. Called from poll()    producer_send_error)namemessagetopickeyvalueproducer_send_success)r   r   	partitionoffsetr   r    N)	r   sendstrr   r   r    r   r"   r#   )r   errmsgs      r   r   VerifiableProducer.dr_cb)   s    LLALII4"%c( #		!ggi #			- . 	 NNaNII6 #		$'MMO!$!ggi #		- . 	r   )r   r   r   r   )	__name__
__module____qualname____firstlineno____doc__r   r   __static_attributes____classcell__)r   s   @r   r   r      s    
	 r   r   __main__zVerifiable Python Producer)descriptionz--topicT)typerequiredz--throughput)r2   defaultz--broker-listzconf_bootstrap.servers)destr3   z--bootstrap-server)r5   z--max-messagesmax_msgsi@B )r2   r5   r4   z--value-prefixvalue_prefix)r5   r2   r4   z--acksztopicconf_request.required.acksz--message-create-timecreate_timez--repeating-keysrepeating_keysz--producer.configproducer_configz-Xr   
extra_confappendzConfiguration property)nargsr5   actionhelpr4   z0.9.0)zbroker.version.fallbackzproduce.offset.report=
throughputr   z.%dz%dg      ?z'Producing %d messages at a rate of %d/s)r    r   	timestampzproduce() #%d/%d failed: %szHLocal produce queue full (produced %d/%d msgs), waiting for deliveries..g      ?)timeoutg:0yE>Flushing   shutdown_complete)r   _qlenzAll done)3argparsetimeconfluent_kafkar   r   verifiable_clientr   r   r)   ArgumentParserparseradd_argumentr%   intvars
parse_argsargsr   getupdateread_config_filesplit
set_configvpr6   rB   r   	value_fmtr:   key_counterdelaydbgrangeirunt_endr   r   producer   er&   r   BufferErrorpollmax	remainingKeyboardInterruptflushr$   len)xs   0r   <module>rl      sK  $   4 .#) #L z$$1MNF
	d;
S!<
.FQUV
,3KL
(sWU
(~CQUV
s1R\^_
/cWXY
*;KUVW
+2CD
ALPhrtu!!#$D'.%)+D xx!4(4$55d;L6MNOKK$((<*DE*DQ1C*DEFd+	D	!Bz"BKl#JMEN'(50		*+NKA~JFF4Z7PPQ%q"++&A66IIK%'E&&!Q&,C#.?n"DKCKK''i!m#26((=!2L ( NKK1$K 
 5499;#67	   3
*	 ; 'N FF:
! GG(3r{{3CDEFF:} , FR & $FF8Ar{{CPQF;SSTJJ!OJJ" FFer{{+, -KK$$S$1	     si   +M(O+ .;O+ *AM.AO+ O8 O( <N!O+ !AO(#O+ 'O((O+ +O54O58P P