+
    Û1j%  ã                   óz   € ^ RI t ^ RIt^ RIt^ RIHt ^ RIHt ^ RIHt ^ RIH	t	H
t
 RRRR	/tR
t ! R R]	]
4      tR# )é    N)Údatetime)Úcached_property)ÚOptional)ÚPluginÚUbuntuPluginÚCONFz)/var/snap/charmed-kafka/current/etc/kafkaÚLOGSz,/var/snap/charmed-kafka/common/var/log/kafkaz%Y-%m-%d-%Hc                   óv   a € ] tR t^t o RtRtRt]V 3R lR l4       t]V 3R lR l4       t	R t
R tR	 tR
tV tR# )ÚCharmedKafkazCharmed KafkaÚcharmed_kafkac                ó0   <€ V ^8„  d   QhRS[ S[,          /# ©é   Úreturn)r   Ústr)ÚformatÚ__classdict__s   "€ÚB/usr/lib/python3/dist-packages/sos/report/plugins/charmed_kafka.pyÚ__annotate__ÚCharmedKafka.__annotate__    s   ø€ ÷ ñ ¡(©3¥-ñ ó    c                óN  €  . p\        \        R ,           R2RR7      ;_uu_ 4       pVP                  4       pRRR4       V F:  pRV9   g   K  \        P                  ! RRVP                  R4      ^,          4      u # 	  R#   + '       g   i     LR; i  \         d     R# i ; i)	r   ú/client.propertieszutf-8)ÚencodingNÚ	bootstrapz:(?!1)(\d+)z:1\1Ú=)ÚopenÚPATHSÚ	readlinesÚreÚsubÚsplitÚFileNotFoundError)ÚselfÚlinesÚfÚlines   &   r   Úbootstrap_serverÚCharmedKafka.bootstrap_server   sŸ   € ð	ØˆEÜÜ˜V•}�oÐ%7Ð8Ø$÷õ ð ØŸ™›�÷	ó �Ø $Ö&ô Ÿ6š6Ø&¨ØŸ
™
 3›¨Õ*óò ñ	 ñ ÷÷ ûô  !ô 	Úð	ús3   ‚%B §B¸B Á/B Á>B ÂB	ÂB ÂB$Â#B$c                ó    <€ V ^8„  d   QhRS[ /# r   )r   )r   r   s   "€r   r   r   7   s   ø€ ÷ 
ñ 
¡#ñ 
r   c                óf   € V P                   '       g   R # RV P                    R\        R,           R2# )Ú z--bootstrap-server z --command-config r   r   )r(   r   ©r$   s   &r   Údefault_bin_argsÚCharmedKafka.default_bin_args6   s:   € à×$×$Ð$Ùð " $×"7Ñ"7Ð!8Ø ¤ v¥ Ð/AðCð	
r   c                ód  € V P                   '       g   R # V P                  R4      pV P                  R4      p\        P                  ! \        R,           R24       FŸ  p\        P
                  ! RVR7      pV'       g   K%  \        P                  ! VP                  ^4      \        4      pV'       g   KY  V'       d   Kc  V\        P                  ! \        V4      \        4      8  g   KŽ  V P                  V4       K¡  	  V P                  \        R,           R2\        R,           R	2\        R,           R
2\        R,           R2.4       V P                  \        R,           \        R,           .4       V'       d   V P                  RRR7       MV P                  RRR7       V P                  RV P                   2RR/RR7       R F,  pV P                  RV RV P                   2RR/RV 2R7       K.  	  V P                  RV P                   2RR/RR7       V P                  RRR7       R # )NÚall_logsÚsincer	   ú/*z%([0-9]{4}-[0-9]{2}-[0-9]{2}-[0-9]{2}))ÚpatternÚstringr   z/*.pemz/*.keyz/*.p12z/*.jksz%snap logs -n all charmed-kafka.daemonzsnap_logs_charmed-kafka_daemon)Úsuggest_filenamez)snap logs -n 500 all charmed-kafka.daemonz charmed-kafka.topics --describe Ú
KAFKA_OPTSr,   zkafka-topics)Úenvr6   z5charmed-kafka.configs --describe --all --entity-type Ú zkafka-configs-zcharmed-kafka.acls --list z
kafka-aclszcurl localhost:9101/metricszjmx-metrics)ÚtopicsÚclientsÚusersÚbrokersÚips)r(   Ú
get_optionÚglobr   r    Úsearchr   ÚstrptimeÚgroupÚDATE_FORMATr   Úadd_forbidden_pathÚadd_copy_specÚadd_cmd_outputr.   )r$   r1   r2   ÚfileÚdateÚfile_dtÚentitys   &      r   ÚsetupÚCharmedKafka.setup@   s3  € Ø×$×$Ð$áð —?‘? :Ó.ˆØ—‘ Ó(ˆä—I’I¤ v¥ ¨rÐ2Ö3ˆDÜ—9’9Ø@ÈôˆD÷
 Ùä×'Ò'¨¯
©
°1«´{ÓCˆG÷ ‘ß ™Øœh×/Ò/´°E³
¼KÓHÖHð ×'Ñ'¨Ö-ñ# 4ð( 	×ÑÜ˜•=�/ Ð(Ü˜•=�/ Ð(Ü˜•=�/ Ð(Ü˜•=�/ Ð(ð	!
ô 	ð 	×Ñä˜•=�/Ü˜•=�/ðô	
÷ Ø×ÑØ7Ø!Að  õ ð
 ×ÑØ;Ø!Að  ô ð 	×ÑØ.¨t×/DÑ/DÐ.EÐFØ˜rÐ"Ø+ð 	ô 	
ó GˆFØ×Ñð%Ø%+ H¨A¨d×.CÑ.CÐ-DðFð " 2Ð&Ø#1°&°Ð!:ð  ö ñ Gð 	×ÑØ(¨×)>Ñ)>Ð(?Ð@Ø˜rÐ"Ø)ð 	ô 	
ð 	×ÑØ)Ø*ð 	ö 	
r   c           	     óö  € V P                  R V P                   2RR/R7      p/ pV'       dD   VR,          ^ 8X  d6   VR,          P                  4        F  p \        P                  ! V4      p M	  V P                  R4      ;_uu_ 4       pVP                  \        P                  ! V^R7      4       RRR4       V P                  R	V P                   R
2RR/R7      p. pV'       d-   VR,          ^ 8X  d   VR,          P                  4       R,          p. pV FX  pV P                  R	V P                   2RV 234      p	V	'       g   K0  V	R,          ^ 8X  g   K@  VP                  V	R,          4       KZ  	  V P                  R4      ;_uu_ 4       pVP                  RP                  V4      4       RRR4       R#   \        P
                   d     EK}  i ; i  + '       g   i     EL+; i  + '       g   i     R# ; i)z"charmed-kafka.log-dirs --describe r7   r,   )r8   ÚstatusÚoutputzkafka-log-dirs)ÚindentNzcharmed-kafka.transactions z list:é   NNzdescribe --transactional-id zkafka-transactionsÚ
)Úexec_cmdr.   Ú
splitlinesÚjsonÚloadsÚJSONDecodeErrorÚcollection_fileÚwriteÚdumpsÚappendÚjoin)
r$   Úlog_dirs_outputÚlog_dirsr'   r&   Útransactions_listÚtransactional_idsÚtransactions_outputsÚtransactional_idÚtransactions_describes
   &         r   ÚcollectÚCharmedKafka.collectž   sÛ  € ð Ÿ-™-Ø0°×1FÑ1FÐ0GÐHØ˜rÐ"ð (ó 
ˆð ˆ÷ ˜¨xÕ8¸AÔ=Ø'¨Õ1×<Ñ<Ö>�ðÜ#Ÿzšz¨$Ó/�HÙñ ?ð ×!Ñ!Ð"2×3Ô3°qØ�G‰G”D—J’J˜x°Ô2Ô3÷ 4ð
 !ŸM™MØ)¨$×*?Ñ*?Ð)@ÀÐFØ˜rÐ"ð *ó 
Ðð ÐçÐ!2°8Õ!<ÀÔ!AØ 1°(Õ ;× FÑ FÓ HÈÕ LÐà!ÐÛ 1ÐØ$(§M¡Mà1°$×2GÑ2GÐ1HÐIØ2Ð3CÐ2DÐEðó%Ð!÷ %Ñ$Ð)>¸xÕ)HÈAÖ)MØ$×+Ñ+Ð,AÀ(Õ,KÖLñ !2ð ×!Ñ!Ð"6×7Ô7¸1Ø�G‰G�D—I‘IÐ2Ó3Ô4÷ 8Ñ7øô; ×+Ñ+ô Ûðú÷ 4×3Ð3ú÷4 8×7Ð7ús*   ÁF6Â	(GÆ!G'Æ6GÇGÇG$	Ç'G8	c                óp   € V P                   '       g   R # V P                  \        R,           R2RR4       R # )Nr   r3   z(password=")[^"]*z\1*********)r(   Údo_path_regex_subr   r-   s   &r   ÚpostprocÚCharmedKafka.postprocÓ   s5   € Ø×$×$Ð$áð 	×ÑÜ�V�}ˆo˜RÐ Ø Øö	
r   © N)zcharmed-kafka)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú
short_descÚplugin_nameÚpackagesr   r(   r.   rL   re   ri   Ú__static_attributes__Ú__classdictcell__)r   s   @r   r   r      sQ   ø‡ € Ø €JØ!€KØ!€Hà÷ó ðð, ÷
ó ð
ò\
ò|35÷j
ð 
r   r   )r@   rV   r    r   Ú	functoolsr   Útypingr   Úsos.report.pluginsr   r   r   rD   r   rk   r   r   Ú<module>rx      sH   ðó Û Û 	Ý Ý %Ý ç 3ð Ð7Ø
Ð:ð	€ð
 €ôD
�6˜<ö D
r   