From f7faed8e07df4c9552708f2c404afd7960ba0327 Mon Sep 17 00:00:00 2001
From: angelozerr <angelo.zerr@gmail.com>
Date: Tue, 2 Feb 2021 22:09:07 +0100
Subject: [PATCH] Provide an option to clear the consumer view

Fixes #40

Signed-off-by: azerr <azerr@redhat.com>
---
 CHANGELOG.md                                  |   1 +
 docs/Consuming.md                             |  32 +++++++++-
 docs/assets/consumer-view.png                 | Bin 0 -> 13872 bytes
 docs/assets/start-consumer-from-command.png   | Bin 0 -> 6769 bytes
 docs/assets/start-consumer-from-explorer.png  | Bin 0 -> 17189 bytes
 images/dark/clear-all.svg                     |   1 +
 images/light/clear-all.svg                    |   1 +
 package.json                                  |  15 +++++
 src/commands/consumers.ts                     |  41 +++++++++---
 src/extension.ts                              |  12 +++-
 .../consumerVirtualTextDocumentProvider.ts    |  60 +++++++++++-------
 11 files changed, 127 insertions(+), 36 deletions(-)
 create mode 100644 docs/assets/consumer-view.png
 create mode 100644 docs/assets/start-consumer-from-command.png
 create mode 100644 docs/assets/start-consumer-from-explorer.png
 create mode 100644 images/dark/clear-all.svg
 create mode 100644 images/light/clear-all.svg

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 15ccdb0..bfae418 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -9,6 +9,7 @@ All notable changes to Kafka extension will be documented in this file.
 - Selected Cluster or Topic can now be deleted via the Delete shortcut (Cmd+Backspace on Mac). See [#79](https://github.com/jlandersen/vscode-kafka/issues/79)
 - Added SASL/SCRAM-256 and SASL/SCRAM-512 authentication support. See [#3](https://github.com/jlandersen/vscode-kafka/issues/3).
 - Added the option to enable basic SSL support for clusters without authentication. See [#84](https://github.com/jlandersen/vscode-kafka/issues/84).
+- The consumer view now provides a `Clear Consumer View` command. See [#84](https://github.com/jlandersen/vscode-kafka/issues/40).
 
 ### Changed
 - Improved the "New cluster" and "New topic" wizards: now include validation and a back button. See [#21](https://github.com/jlandersen/vscode-kafka/issues/21).
diff --git a/docs/Consuming.md b/docs/Consuming.md
index d278bf8..911e97d 100644
--- a/docs/Consuming.md
+++ b/docs/Consuming.md
@@ -1,10 +1,40 @@
 # Consuming messages
 
-Consuming topics can be done by right clicking a topic in the explorer or from the command palette.  Some things to note about consuming:
+Consuming topics can be done:
+
+* with [Kafka Explorer](#kafka-explorer) by right clicking a topic in the explorer.
+* with the [Start command](#start-command) from the command palette.
+
+Some things to note about consuming:
 
 * UTF-8 encoded keys and values only. If data is encoded differently, it will not be pretty.
 * One consumer group is created per topic (may change in the future to just have one for the extension).
 
+## Consume with ...
+
+### Kafka explorer
+
+You can start consumer with [Kafka Explorer](Explorer.md#explorer) by right clicking a topic in the explorer:
+
+![Start Consumer with Explorer](assets/start-consumer-from-explorer.png)
+
+In this case, you cannot configure offset, partition and consumer group id name. The offset can be just configured with the [kafka.consumers.offset](#kafkaconsumersoffset) preference.
+
+### Start command
+
+![Start Consumer with palette](assets/start-consumer-from-command.png)
+
+## Consumer View
+
+When consumer is started, it opens a read-only editor which shows producing messages:
+
+![Consumer view](assets/consumer-view.png)
+
+This editor provides 2 commands on the right of the editor:
+
+ * `Clear Consumer View` to clear the content of the view.
+ * `Start/Stop` to stop or restart the consumer.
+
 Consumers are based on virtual documents, available in the VS Code extension API. A consumer will keep running even if you close the document in the editor. You should make sure to close the consumer explicitly, either via the command palette, the status bar element or the start/stop action button as well. The VS Code API does not support detecting if a virtual document is closed immediately. Instead, the underlying virtual document is automatically closed after two minutes if the document is closed in the editor.
 
 ## Preferences
diff --git a/docs/assets/consumer-view.png b/docs/assets/consumer-view.png
new file mode 100644
index 0000000000000000000000000000000000000000..ee0c2b7f6a8791ff6820a498624ad0843f796c38
GIT binary patch
literal 13872
zcmch8XIN9+wr-H#K?H;ds0b=mAOsa@0-+h{ND(mf5<sPQ3rI5{A_|1wJAu&aNAJBQ
zbOGr_dWXC4+xwio?>*-{_x`y&4~wjowdR~_jxopkj(1Fg)SfF)Q?OEiKp<)*ML7)+
z=*k@sh#-aR3UDQ&D|!t0L*S^P@D!Bab7L7eA+nT#%YZ<IVU(u`V&I(owW6LQ2z1ry
z@|R%Bg2N325^YwJlhJZBTAw_NU>o*c+&UB4o*7W31Q!W^hbbzCyD(9GR^yX?82SMw
zH}XkXHv-f0&?x<Nq<OC#c~v-Xi(bK839gVyii_7&<@S^NH-lJEQ7qPUCU@R{QU5|e
z+y4p0tF2^*_l&RHe3Zelq3JrkQM>sfPQzYmqE=$!&}$)fV|lYq&u^?^t*Fx)!kYJD
zy=`}Q>u6Cm!F~B|LHxz?D)Y40>bmRn2@66~c8XawrQb>(+K_JSX8Z&NOJT&5p?!XO
zZ$Vg5I%b^6WB-HZK`V%UI101O{QrD2<Mh-?U)_4b!r2<+A3f-JttJRWVS@hIqmCEQ
zNd-Ohtl?zVx_B0hFfHpwi%D%YG4z(s^d-rTmpL3v8CAe=yOf(D8U4WyesG-Re&L>~
z)Y<OF<b`Kzs8rcFt?!{MJ-_eK4`1to)0G!>9*4hwdTyS@x_+?{{f~ZCmOnVu9)0gd
zJ2>P7mAR4LSG8q@)*W~z(8+!m^gZgFI(G2cL7S92u9t9>yx?AcnfKirN0rCMI=yA-
zyJgG~Xm{YXkF}73I5soBnD9QBoHfQGmGIx1{tVnenfZx`$W9LQvT5rw?|Dv@+U>}K
zm)?8BQ^y-%1cMzupnEdmsJA!43-PmS8CU9h;e$19`baBzSa5M%Aaz(z+x2$(q{p>(
zNAO}>Q0llptXhpe#3T)O$K^qe{tRFe{jEG}=9jM-5RUV0;TZ`&$N5zo+fZk~VphEU
z5LU!of70!9G|ru&s)+H@R*cgfEYLBr+AWlALCwhc&!oU!-}9X*$wCw+sC2Dyp@X-e
z`sh1aY{J79mtVQUgU#!ma2dDzAz&C26C>QYzLVT+01+=~`R5CIO?#&p+eWyBxPEa#
zvq8r!rB3ubNy7y!WZz+y%Nd1G(0$7}3xkAZNu=L{S3bE;-yt6^-KV+io511t^pwOP
z_ZHLU&Gk|%99fm?<~go)WR=Z^1)8IC)^ofkb~fT*NT07)x|WT$uRLnxs1<(6SsLu!
z6#p}3!=NI)-)AetIM8=*7LT>;cK*xwj3?HhYBAokNzx;2$)z!_(O$yqhwe4ry%F90
zq=vZWapIbfGimZ}uTN5%D}v?%eVdhQv=j2;8Ha3%yy-m62SuostB-t@EtNPgU0=t`
zc8r*L!lV&KS2s*e>%b&FB#8X<X+&~wNYl~Lk@m@N>GJKL0d<aRxWY}JgDS+8pga?f
z!VH|$L|&)P0EXVs5yu=-JHAodm~WhW&9HPTRrA)%A(^WiENQNN;*_`LcUyx*O=@u2
zqvIhwpPtbK?IETDM_t|q(o#<+_wqcUK9Oza-dbNNgUI9hR{ATcz+04VYpbCKNSxQQ
zigD#^@bri{9W;#wZNC9y@Gjh_Uyql#X2_D?KUrBb9GY{laCqv`>5>)M@?=x`!IY;U
z)h%)PwHf+qxxz;7(`z-j+i{Rt&L~)lc1@a7{q*_%#$r5L$wqA2tFzROlf&!x`}6Ub
zlMOIqK|w`JUHr8DPQ!xd^vM)|84}~V6k%Nqtg;TkGWecNn`bHV4s@7t=TT#a{SeHF
z$yULVwm-&pgw6FjVT|rj(5&<7)9X-=h}bfXU3xjcs9(~DdI*{z934T*i(uF2Gd=_^
zaFE9F9v716tm61Ek1PU4`nk-?#Rm0Hf6<-1`Fm6eJ|Db9(Hr}SQ+UDF_$20#qn|VE
z$t+vaM~i^&MX3wp>b&G2tDx=uAUks!v{A{n5tiPGxxiG~b)u4iHb`Dv-K4RFuS(9<
zVH3%akVY!>v%XpRq(lK}BY`BUDT-_hLVXY2`G<cG3OuX{s&+ry3z_v5C#5<4SeAuN
zZ?qWAHx!$AFmJa~L=WxP>4U`Ra*m)SuF5sSFekSC;+||y<=kU=83FJP9q)VLOtWo2
z2~2z8wqi)grePtw&*9Hqsg-NuQQG{!Yu#A$4oA#!f&F2Mtl?rmz4U*;{kl0Wwi4WU
zMXdec#pWE)!mu2A+a?dJ!j&r71T=b(t#Hyf1U@TvjM-#5D`DRa9PPI^tbQKMP%r-N
zkZ&vKxa4Li-xRMOA~8(RkCdwS0T;0JXo$CxNNH~L6&R3%>3N>yf6~eLK0w@?Dw)6F
zB46EywVa)PmXDtwy^I^nkeH>!y^9EP7r&)1eXHv|m6I6yHCg|pwB^6ZWS<UlBpom}
z^eWS$e`_|KE8R7w`a25WH^f}eT9OM&D=-}QZLTnF4gKv*ZZL?^tMS;2m+%a|@#wZj
zlgsXsdU#btM1+N2bZqQnx8E}h-P`tSE2SJ~ZkwiIQd?d1vI^;8Jw0q_-}9z+W@Zm2
z=sufq+xNenAl>k_oj$Kr*7az+>2t2CZ_*lI4vxCzbaYMGi~O^K&Gm~7TH3XvlXh=X
z3wCjc@2iz&%h32`IIdV2>lf<&XH8#%OC%REdFRzXS`}+ZPcYbQgc;8tYK!}Nf1vq$
z?f<#Yij}%z`;V0XxN-a^_%&ZXGH$BM?zYf3zuPsj#c)?O-eb87pHRKMV(SN|{?DHN
z1;z$@*EczQS2$?c;~zg37xSHM3dvBd+3o0D>|ub4&i{$#0H!XMUKHM?dE#xg-R3CL
z8lT{c_}M%t7*bFD4{T<f2H@EKgguhMIv@j>Dt4)K_Qd-nV*l3dnOj1PqNj_^aYaSN
z+}(I7cV#MjGBoRdzKZ93>j}H(X;y~zSXURDlmLmCU_3X{rtKe)JJ@U2%jvmij&9Uc
z$gm6zs_#Cfl<=Ut`}WtLVZxp2&jza#;`Ylf6h7OX8-2Eme*`&N3ttTFVMj~&e86Pg
zx^xPw;@jh{zQ4;neTonITjS~8IR5@UKfmiZDB|eN1`Ru13P_G72Hi_zOejCeMoT#l
z^ScVvyxI9{(_XLSs5VDz3Tw7h%E+q|n1>c~U}s@D+Rc#i9=9tCVoo^fvMhC&&YzA7
zS}mwMZ?qdb|0Q^VPq=9I9Y2b!J6`!{e6neL!7+V^t~*MYzKtXUgVOeY+CusCs+K##
zd|no(iA_oVF3eN0pYS^Rs{O*yITGiwnpbAzI_d1YtKeJw_LuUOiJP0->PX%(Dq6S1
zCenSlXs$IZ;j#0|>Cuiu^;S#OX6;EmDaYxK)P)E_76+2P-M~%gM-58lL<&pehQ@KV
z{{G8B{1)Vy*|wWLzgJKPRJj+b$G5vPB=@rT4N8$ZyEGNIFYk2{%%G8oXuJx|3<#UR
zylF?Fe@r?lxP`--x~PMvZoP1(L?_var`pL{RM5%bKGSYIt`V|Y-8fCfe`cbCN>Alq
z3>tPiob7&18vpL=HP1PEQG5PkIw8IF@$~6}*j~JQraCT{jsCt!k&EJaf{`DpE9#`R
zJ6k?Ppvv)LJ90rZ<~H(OwPCGU<n@t2-vV9tvq+A!@_#e|7PBAnTu2f?V3BT4t%1r>
zQ~sz(2>pJd<p@nu^FdCaeubwYrg4S@s}vzlgkI|(Fn8^-pD6Jy)Vn&bu*9}2G)&V|
zzs`xy3ko=!-;T3bZHcQA6al07X}kIO_}1V@Z%pmtzBq{Nhc@RH<Kn8Yy<Kv1_Feo8
zgOrpfEo*ER>>8W4zc3*!`!OX?UrQ34i9qR~nYFg(hXp#+zD9s4?Q1>eBuvawNFm0j
zv&<ZBGXyoNJ}a)>>6VB&f4Rm_XD$Kxo=2}2Z>l^)X6B(F8V2B?qQmo+^qY)N?Qv_d
zhIdV1KD%p`akGXzPd+?!qRB~a6PH-^(|-2&QFf)9%<gucW=);am71km3HRLxrK9?S
zuD0{=*W5p2-mq}EP;j%4NN_mgU{g(efDLQ8WXpmOD66;9j&l}5Mg4>^2KE)dXwPS8
zcO{Q*A%zngTUHM2o(mRaiq^lD**igz^&9%q$@d>XA>?51E?AEq$BLJq8HaKJszzJ>
zhe){+7|&-^YoVrFF~mn|Muq!$)i{T(lHuxO<eE&-ja<lW{v%BI-UxVDq4=AwbQ+b<
zO7D;9W9zd+5YT&LOamR1MUfKhI+2KvtD26iQc5)8lyr#kLrJDnfSrqBIJv1zSM>1v
zjMA7<Hr?u{=G`+hF^n6&w8I}W=HZ=em27u;kQ&pGuXUv&x{`)osmN!E<iK!=?B{1O
z&Ykv^b7e0kF}p3}&22DRTMAj6S)w%#M@U@1(Kpx#Qxnf=dn21OhY=!J5Ob6?`~;tE
zgDF?Rz78av{7|i=1xI+%`%&B2b$&NG_Z31!5U@dwlCK9L1_#<&k_Q?((4mdo+c1SP
z#2|&Ud0I1#gs}OK!M61G7#YJ!V8JeE3j%M~hlqInMt*O*-xgXQ^Su%FdTPlMHn;sO
z0#kUmJ6WF`tq3X>d`o_JteLm}p|v1#fClaK@uRD~$8|YeqLDq$skL?Uyx~}UgZ{$4
z`k>Q9-MHcCEbP1|!TxlTU+i3A>o^}>a1vn<05z<GRnvvc?kyx;+&r(DGaU^UHBog>
z{7w&Ld4Rxnl1H{o;~^ei?W^6IjTT-Hin4?vEI4#(nDWvv{RIppV*Gxnl`MZ3fUd>W
z`nFGYf<z~RLZL(PGNT;Nd`sA&N&)bff?3OwJA+wBbo?!(niQ{tuJ2&n0Zo|X>p2b|
zeZEgWUZ1~SpBZr;J>6LO#bH=GU%EPqyk4#UXIx|2oeiQMizCC_NUavR&$*&#$FxRR
z!26BeMxSZ225HfZ9}dDrZ^H1p1(~nN!tQgXmSDo?B}c+12{b)$P7jOJ3+V$_tM(A6
z78;pSrP~Q(U_2Rl0LrK$=(EL#$Zaw|>g+IEXryHW2}t=f@Ie8HdyoG$?t$(}t>CrT
z5rm1SnU<RFe$?-_Q{v&j=%JvFFb^o`-9*|D_Gn^JGUK3~7C{K|zLgdaCspbb02(~L
zvWEnLDpKO9K{s8WfT=-W#N$!l85iq&o1bj5fU*NUpllIJ3?yBDrK@j~fHc&4xfvwx
zC6R#4TSU=M=%66LZ{alGslzsKLY3Bk@m&FVWPeA9+)S}(UHUDIr2;MG9s8r6vu@CU
zK%{%fB1kcuo0`E2G?Nq$w@_pSDQZ-BKnE2p6Qs6gRRrV2FT$j1+_v({rjL$#ea=;D
zXu)5BUbXV$;rAP1lRiw%kzi1t#tMFIqC#^sBH{QmF#7wzIdZI6X)}W3@{OMUTEPPY
zQ<I3yvAl$cJ*^GA6@U?1s=wk<FyKOoc5*y5Fb|P0&OM-if02)00}`5x^D}_4J@h*K
zy}P?RF)?v^`UJQwO{c;Zs;Q~j8p<Z_yfRebxG3<l{Pprcn(LH%0EPf`XXPd`TkQ!o
zNR8W%`sJJ_^V5@-u8zNOl3011xV_GmOrjNhqF?E=XRUsyLT8gt7=r9i9?<9q#E)hD
zB{$uFZ8%pwr?r2e62j#D_NZqN948tH4BJ@~m>9<Ecq-)AcFmVl<p@W792V@_EnsZT
zloNy@SV@1ohvWgWJ&1<cEm3hKbS(@#7*!Z*gSw$nIKQ5|KT&ZajJ;>)uDH9t?!2)*
z8yrXxNufWt9-jF{TvfH)b%p^dJ(&tP#_?!f{-t9?_{09jxs4vxm0^O4w{vId4lb<{
zJ={uc9TFc_4*XN|rJld$@-6TQ3(koS%CmWoAvo4hmO$^Vj;?xdYxZK)xsnw=b!nVG
z!)3|@#oY*2{&5!4{dH!o^w39W#2SfO<4Z#!nFNhR?&ZF;`A*FUm8m3i0lY}sIQyjp
zSPaR|QMXaKS}?61j8SJvLD2|`@P;Hdz~JFWkABLBa1(OJ-g8W!oSoxoo@L~*B_SQn
zeJzRarEMTt@&t^nIfb#-P2Yfz>kQ#q*zx5*47%j>ibY+pS77XSV-dFSjy7QOUu8{T
z`?Kkw3!jRUEe4+90$+sNKH#U)X~+^eYUs_T0aneENKYs$f}x)bEW&SL{L_`Yd$v7r
zfH0-4n^+^jHKl|VYPuaw;78r3%A?*3t2W<T89(=^>_T8&<c!Le+w*!YQcapajm1co
ztCx`nGS$p;X8IT_t{l&$0!x9}5wfR$6ZuY36YxGBqz>)W`Dhvi*u4Oo_Lo6Fkr<MQ
zjeX=nbKP6hO}?xxHI19*Pm1V=lDTy{=19dm#b6Kb{}OS1L3poX#Sj~P_?Ze_->;#X
zqW$bN;lmYai)`2Kg~GaW6sBE=a?}}=*g%G!(j0XgtDa*4@%Uqw(`ITxUrD4lvS0K9
zbMdYt%SZwYEE=AGKXF36mjv{sD%AsOYHC^$Y7P0boB#vAYz2f3AaEqj?p@Nl%n!k%
z*jq>s6{%k$=j8FrTI+=I;e@-WKUd$5%qv0L5ex>1v8OoDSsL(22QxJLE4+}_2P#oJ
ztU*apoHo~*E=q}hTbKZq*ijSoy|{8L!?l8c28XkWyF8ok{<k%j0YRitK0UaNWR>;n
z$tX41mBB52kdVpx@J6roT{XeB4ls|N`)l|*-;4Kzq%<6oPb4HH#Kgp;q>R5~SjI|C
zfk>nlZvL295J^;Elp(VFCf<)p?nCs@SGa<TQ*o-n^(Xr@&smR396vCTgzf1ShM7A`
zj)n3Xs%s@UI^{4K9Ee0d`vLg7g_7Ey=e-C*Gav}#!-*d&1pHt$V9*czgwkj5>po0m
zBw6{1MhQr+m4n4Y<ZYSqm)p3l0~R>J(Sbg=r5$o#rUT^1>mnH$PdiVnL<P1QIOB{L
z`S10^xYTYML{?esOms~IF*6xSo<xiaRG+t`l}&qZo*hUX%Cj`Um{y0<5<NMf_nZ4-
zZ)}UZ)>DQ7DoIO__A4z+qiRj5B<}{Nh60q3m(*XhGq0?CF9R;G?oMYh@b2;QO=Nn8
z<zj-A`$F0aBZ-T_5awx*lemP7wZ)5}6HFmtdMhG@DPoiU^<$@DV^4|Nls-&Qr{e0N
z&o$8tve5x;VOu}#?H5<_=%FKPEC|9O_z%R+akCiEh~?(l+Qt53<d8Q3r){@}Y6GlC
zkhpubKs#e?O>Gvlr3z!8zL7DGQDVWDM_Bt&f2rvh#y%33aP&I&AGGW_pC6`_@;=jG
zX|Rxnb(g}*cYRp9lOtNj^tZ#|FL7p&q9Aj74;sq>B9Ul|?;x{eAm*iqK5<<;4ARUn
zmOO|UmBUpZjd*U>9>}ORroX9j)VdWO!36EkSz7mp57I~op=Q4}(qlhz+}()LY2e<A
zf%9#^2r1No*czd!uoxPr`*3f7ckz6yL3O%(ccH3=1|6t@LJmQ+`Z7ov?DGOp!9;?f
z8$pN^Dc)bbDsuyE;vCM~h}dE}==wCu!eXGoOGDw6E}>aIFtYf#*myMB_s!2VY(cE=
zdPB3AK+R51)g}Wp2r+kV7_t;I4j{Wt!VH;A{zKl63zlCgvJ;83=!oJ6bIXIz9&#mw
zqf#&O2X9)xdjbSzd}RsBm{xpH26w|}zpZO+D?%{-k>~!fuh;r)v)GgmV8I`}0Q|*&
z^MEECHr)l7E?{XI_82ew1svsF)f%t;yDOiH%ccM`0VwxPAHc=6@v_aVjQE(?*x2ak
z=!67gU0t`MUq8sfpnD~NW!x8{Ez>hHRAV1*4X6m#9Ixa6nclI1LybHDn_1cbjt0=M
zT{Vq~xT{*b-NDN&@X~FkTWs2MQv!$-%6V^lVU!9`!MfA!qn$-TqiWsstAwC;7MDTN
z7*nV+76@e2gdlAVV8N<<=VQ5ko$fC8hu6P4A`5Ddv#(EFg0>B?4(9y30Znv!%(eiC
z#s9prJebj&Af<`}RDNd;s9^Q)50?+{zm8{MaF>IxrI>>fnJQ_~m+9go$4?k*?z6(E
z?)Xyt`*PAB1WU#MJOItEt*vEgW_Ykevr|zjKLQ0l@0@lhW@hFE(M~vV<j103Ho~+C
zzVvo|zIH{8b{2Av0rX7~m^C+q<L**F@Y3Hok-5j#%>%v8G@dR;PG*~h7t4meCeiN%
z=C4Du%k?17ovv(kStQ2tyy$JAL~|;H#y)(LT-V60e;o#o5%pyCl~o3yG0ZyL9a`lk
z<93B-#U$opIa|)cz~7R}u))2H_YKS)o;dOM^X={JiwVB91&!PqA(~_qPLF?_<)ts+
zwXVoR^^#`c1^l(sp%6x%dat<0-x%DwVNi?OoOO*083eo_KK*&3(NqiVO>H2216i{H
zK$f00SorwVI*lTOt6$AUUK^~gS61KzN9vLvT$7_&+MM7+{zm}ebofD^w$n}x);>c{
zM?FsOclk`vrujD#=pP_<*08<bZy{gWDwxe&6YW!?0_PNL-b3!nnCx(K2aE-mIjOv8
z&!yL?2)85s42D|74n@H<hvVA8iBEtx<7S1nhH(h$;rR3cI+zNViA-_?;}us>=ezo|
z{?VTsxP8p#j3R@`(cV8(W15;+)p#z^9fe`RK`Jk!xiB^=r@TFXpSwh(fjf}~*M=@;
zf#&64f)LytU0*q%=Q;p0QBGUwh4EVAGF2X?G&a91Q=dFW?%EgEQ(Gu4Jw_7UeHBy3
z<q;OkyB-7AnsZsa$MPuLDkz8pB%!runGz|49J-+|)5zL<(#X0fDU_FjVc{r#;ZdfU
zA@x<-sz^4&HHCO09Ho@<+selF?twPpJ!t^IzKI||4e=AaPi}!QiFBtK>|T8yzzJr%
zE`tqF4)*=kGJR{$-F6*?ynTwHkL?euBA0Hzq_#>0cn}Er5=#J@548pOdJN|!CkGCR
zf?73ys4An{-rrPJdU*8@xh2pp_(N`qfk06Kh$4T|T;P7-^!|+MYXGE|D2K4i4*PSR
z8Y(0pX|YU8!X$TZR?rejFRb%xcC^K3d!D8KUK6#izoQn5-wFfCfOM@JR9{Cc@;&=C
z<}c<+oWxhO+?sT#1A%<w9?c%|@m<RFz1!AAdMNIEjSS<Zu43HJ=Pz-Yu6Qn++vW~K
zRbOdylzaHrxEermYQ5>4on|ac;UyMXRx7vbBqA1ik{%I@nSNCQ*mA5#;v1|>_5-Z6
zodxJ6w!LMH{!zXjFX!C{!e*t6f1x2NaSS^o60mUu!~HWBM<N&$^c1-5U4>vGKzI{P
zGRmvpkT8XRdEHL0G>Txr`kH;E26ZGqM~FPG?&4D>R?XF$i)@RMEg%=nZyRyOWj-pl
z0%r4@MooIZ$93pqelz3E)=$q_c}2Ea@gQl66};IkR{s9O_ULG(@fj|;>razH8(}Dm
z53(h~)-9r7P!bRuk4lVBN{lb|j4x2rhp6e(?&;IM07<P-On;fAn7}}0T?JlehX2Zk
z4ieG0UtLM<TCW8c1HJVrz;OZ=<_{d0NIpwyjm><j>IXso*c`~y-A%9UAA&+CK1YGb
zMmo9Qwz1$d?`<2HLI%kmRA|t|-~O2T+t7mp%=z~S?mGa{@9QOHpJlGg{LfqtmH3a(
zNdO34(zAGAxVHfB@!&Z?UUInX3?MRJy3-gCivQ3)Uf(~oFFWAU-6r02lYrD5{oo@l
z2iXC}+j7DntD8vS5+GNJB2ZJlTzf4TA;2Lh_~N<SGx$_hcehz@fbJy5!v(ZX{eIa|
z2$wnlD^BhC5Vl=bFgODU+sdCkpm@#3n5VW+ZGn7rKsn2ja|y^1Ix)-L7}!m~7)*Oe
z;gK8!sx795l2U{=Tolv+B%An^b_}egtD#|Pf;1V_cONiKmTM#H`*0wqoyA+Rtl)=P
zQNW;;Lo8Fw(=!@bfmBG19Pso{tRtUkXrr3hfwr}Xfz;?T@P+<MY!+=iiX^eP+(MHx
zyB4JCO#%Wk9nlrQ>_h+-wXyxnA>zGle#OFer=S=m=pEU=CD{L(Z}$PQpl<b0&^6BU
zB43<|-(zMi-?47O*(<wGU$Hi}$8xKzMPZTS#?i>Oe8`AHyzgr#AFs)E3kDDKJ@zg6
zC*|%Z$?|0mY~jWoH96f(Hwh3C@23K~*)+xF7tfmxx|z(I8#gx}yFw523#j2e8Japc
zK4URGt-ADMHGH&%?MV$Ig-Z0j2m@v`mjWkp*8xOcML=Cbaj94Gar#G=EDuA*_*DaY
z44akiH>9^8IX!dft2E|BQbb;bu84uoKGH$0;C2lbuXKlt$X6&co0GTG4-nX;6XS;m
zopH3{s%^{WxTZMOR#rsB$eH<PjI}6o$N}UzvbraoT<O;>%pw4gy|2YCshFoWTvamC
zF1y=bgQi)9W{lzLKXhw<zw^3JDEnD)w@*&ArdGx{tUqtEuyZ6R+TY*b+ti{^ylAf0
z)p;)FJ^MjasA~6)+hpZ2TeV(U=H0;LZW?w8Yz8`J8cUq<v$|8yx@6>|f^oq>o=_?F
z@!6MSKHfWP32o>1=RLNJ8&64#OZ9DITYeKyW@_U;+uK}wuBk0<D_NxU15%{EIvg4K
zPV{zvfxL*gn|M_SPuW;ISnq?3L@FerSUtrrT&aJjBh=08?aSSh>>X|I!WE&oI~bT^
zH&+-^YnsjJ;5@^Ptwt9~^l=E^)^hf3h~an7gapSyoiyFk1-1T(ui|tM+LXQX@tIEe
zLQ`}X^Vt~7()@iYbXpFHzbNnQ`9X!-5o^VpUmDmoR^6<riYLF~a>n>%VjiN>Vf-UE
zeu(@^YiJ3*?U{qkxTEmsxxHvOw8;9TRm(7A#S;93`gEBsrvO>7`iuhIb_}al;@Mxz
zpB_}l$@NT}U%O~^>bbl9W<N;_r)$6|#ftdIH@reZAW^GM5hFeL0n@L?*>tC4mNA<b
z9+><)PRKBC*)Jmbp1KKcX}qN&8Y1?<4EHbsX=5qj6$A_E;P;Ks6Is8ALd9$OqhdI)
zz7np!+73*F@qU;$De`ZCykIZGOYJU#LBetG{!g!0yF?%0{l%Ex>1k!$%@@vK{8BW;
z(IAHP*EK-s1lI>sJBD+A0le*<$JcIaydT_>6Fk}85`Y?ncg9VAQT#y%wSmytJ@>(#
z94ai`L=Hv!ks^y9AlEoFH`YkP4g~OI;N7Q&4X`O1x*7}3zGwO+`S^Q3{i3`O8S<W-
z=y)4;C~8Ba)@rwhUy%$Q6%N1ctTQF^m<%kga@9{N{fPuG`@mqspTUWeqob^XnpAy&
zGW;_BW{RR;@I)*59Vz5mP|?QSZs9s`o)V6zZn={!xjmdGDa1jL|2C;o8%Ap*RgZ7S
zv_oP&OeL%(9WnU4=t}pHxmilV$f2+0U_zNB>F#=`l55Cv-W0K~6mlX*+{2dnBl^Y$
z%=Rj@GK0xr{G8gbPH1eHJMV>@uU*E6C$fV2Ls_Ms!YdE6K7tuVJU7_3RQcBDVm`qs
z6DW&wVPa&E4Vu1{3!?W6^M7$wm(RkpvTg?52?%D$kuU0~dpp-vA*y-U){?uN+o}~n
z9WzPUX+JhLPbIEJ$_80{Mm3y~u};_N{-O)K7set6qL_tR{qzl9KrpcDl$8>KF+=x|
z9vRh$h!&0#t8iPWHZuyKJJNu7{1p&$3DWHmDLw^ZN8TLLg=A<dtp~_?xK-f~#}!7X
zO>KzEgfuxI`(|q3hz^MFOg>bLz>o`S-7);BY9pb@eL?YMFbX7RczMSH0GRh^09hG8
zo&f*~-c9@;2RvE)v8YJla4rGJj||P1)ppAP^w*0VjF9Nyw+5T1RW17hd~43^DO8|L
zRa|Dw6+{rh9?_CXFuvRj*Y%{hnU4VU4G`0L;unUlsinluW>XOXxEH7%feG&)$c#;I
zQ;s8MRK)@b1zk!hC)kjw@;9%T0e3o(=lmZ26@wBOtl<BQzQrP1Qx1QHG`27gBS?hW
zIDUNhg2}@yQ*6*GSitAmJV-hbhL{VE*5&oPfq$m@AdCc5TKNf8%@AXdK#+K6<vR3y
z4}BYWIl2@m!gPa7&BG}Rb{h%039~D}?~(z?B1DEpUVi@((|#3zo_D%_aOejQ=#y<0
zkO?rj|6*qTn`_z+kY?o1Z>2vN>w}iaFUt#oLDJPW{-|tDjGdx?Ff+7BU*9y1;tn9u
zDknchaL$>T<#{nOK!pusg`qV(l+>WW?0HeN6|PM*rEx^MWk_T2ClR2{dibGYWGPpr
zbBg*nZOx}1L;%9BS{bI$q8FIYdm;M%DDmh^$y9G>DF#K?lS*zO+zm{=M<zF-ancH;
zX5mZ@mWW{LNy@6jB6JBsT<U2UAxHE0mZ9hlG)RdM^h>=xoEns<4>Tve@&9-zZ#fX~
z+ebx5zAyB)2*J2c<PyD0Cj&Q)2@A0?KwCzFSOCr{&I4p#UeZtVSa)U?lPR6@Cu;0R
zmjRY<-Jh%~FzxP<f=z!5bgY-HgKJanO+R(KgVZW1?*Cbmoex)STqqK^6x)a~tR3Lf
zVL%YxRAHn5KeFl9wwdL1Ug@yTW_1#5v}imp7ecYDW{$MoVpN&xvFW`mriBcA50IOl
zGFlW6%n!^|%SsfTVh^II*x7Aj!lnX7FVbqag%)yxQ(6%slI5$rmEuxaFG%M*PzUH*
zJlnxT^d0AW2V~jP%wH?dAJ#{n)*MUl<Xdo;W)lN%^%GbXQ5f})SH&M)ixfBkkiH&o
zw{>QcJBVY&>nZ<BaSF_X{NO~t<_6H7YoVC-4-{Zg`GrM4X8stesMpC|(JmojIoCp7
zWahHmc!_N|GLw=5CPP9VXIB5;Dx_+xesHG$QW#bC$Fx7?M0OQNdHYXCLqhIyD${<x
zEyk?KHia6o!F_JGBmvxdTMlTQ1}vgcXd-I|=a|SGCz1;>+NRg46TIVm_GX{~mJ#wO
z#)JRzR;@HZ>18N{`-gT!1@`|mUx{;fY=rgwL{Mv<@`~;Ed}XEOBGzc(1k3Q-n4~@N
z!C<{i{US6Z9bH91shRU_>7QmVu3ZD!e8AlIXUbm%N&C}7Ycle;irrg9Kw1=tL6v%M
zf;-gznNt19tNyzK&+~s%G!yCk;CNB@ukg3HCY`8KV7$Sa^%y<z<oKl<_l0Jj99Cp5
zO4z2img(Ebyf1Y+#T8p1GzInt(=FNGcCvvoYi<0yzjQ_0$qMZu%?2P>VC!nHrrfwl
z9w&?i_mcvu<~~sxMT<Eb;WkNTG=+cnyS9k%l5K7MElA$XRU0E5nNiJi%cZ#|<otm|
zB3WGM(C<rDN@Wk+*4Sbp+qR2D{8a3#SQC!U1+QYZ7nRAGl8Z|^{G}U~JkbIo3<lj_
z6ITw@xJff3m5s1j(zr~~%R06`B9XlozckwzT2+YEEw=a>6N>!mVkKD=9<&sIl1%t*
z`KA{dDCFqDQ(PUUGj~<+$-t5G)Q78fT33iyQqvJB`KwC^HTq;kga%c2`>i@h=IY<~
zph&Y=U1Auq`00@CDt1=#wzHWC=B=78cETgXz;{gRS|llgn>sT>{}ZaRI3gZ~-)?~M
zb5C>5I4xz@?R$7BBq11ngpX{U-LpBT&ri!S8zIYKHSK}nbg_VRr6#sV366tE)Pny9
zWl>E`loIUD@P0xEM-;;p2g5F<7M6bZGGkzdvY?PA(dhWbXh{9D^k^=Ss9FYQS$%-a
z8o^K#JY|G~toJbt-V=CqLrDDa&1}9k7gD1D-!y9vNu(X(Mtb~!JY8vn!DWfPJs$iV
z@xWy&{=V{8_;u(pR^z-HB7myiQNPR4qC|-pJfF0(;O6hT>rC`XRJvR1{$)K7shMQT
z&O38|r2}q*EB76}UAeFigMJvh`|#-(-ky%cqv+HRJXSJ1MDG_Ny!j?l&)Y4{IG5{I
zA&RVtK0J?#2tZnt|B|EpZz;=vb*g!D@sUut!cdc>J_!h@(cD))HWflk*kK9Z&<YT~
zo63BJi?X!$Q1u=W9emo%q^cRa_yYD+-VW|HlYa907jm8znoaS}%fdp9Oj^QMBzyht
z+bfwF0N5yhvy;t=e9ToM8}6QxuzF*EZF{+G%JgEe>byyqz_3jSsr5#LD{X~p7)k)q
zx`#AtW;M)Dw+3V$?ws*!FUJ3`RWQDirfAk<r?;;`C6__eoD!|b|NPdyzU7zuWic_9
zn&j8;X8yrqH9%QOd_XIcXvcX)?fHx-7#|f>P)f=ngXkXeh*_C&NwWl<<$Xt_WV?i3
zriK&lT+I*%%s_t|j7z6Mf;gP;SX_(}Jrv&kR|oLScH1~O!t_3(5kvAW<2k~VN0v8h
zE<Ts*6KZ(W^&0f}W}!Pngsfe&LFL~LI?+^0$o&X;eFWeXPOR|BLTF`HVj<j~6RcFz
zpJ1d?{UAae*A#ZCjU&1jQZWEN-pmFT(7}BhZhrfsoEoLPZy54SLg+TP-6!}e57Gn~
z9p%!(OMW>5X(}N9%r;0sO`)LW^?c-p0jL?GXFFwbo8gWnu44LtVwDM-e~?Q+mlKZ=
z!6+Hk+}{|nyr8v>J!vWqZLsj_Gg_W}9(S&IC8?bzZVJT|2*zLDU7(Ce5#}~QQ?NM~
zILf{+OD67u{IKs=dB_%ubb3Y9&CYZGJQD01FtnKGeCi6-haiVyTIAV4WZG}d2tk=l
z0H^y>wb8iHem5aD2H3&^0tEr8>qk=Bp6>2TnkV-xg#h#xP>lY^!*0ykVbRc60+5=a
zA6yAiph^fD)~?5>Yd_Rfriu!XWj>s-6uPJ6*5#=Gh=m!bYxiU`LS=<5OR3X_u|n!v
zR=DzJB!rQ@P@8ZT=yfIcDMIAI6PuMJt^m|TYpVKt1ZPfvllICkWn46q_(TvTcu$~8
z4xYM(@_4b0xc`7K@eYrBH#e|A-#@RYox$`oAFW42Txq)Rm$O7X(;!964H2TyCF8<E
z{6(JzqCp-7FhokQGxU?BKhx?icelo3Q?*Q3zY9)I*|+7!r8w~wAgVY5O*dRQVTht)
z`FvpNDkcaoCEN}WD)k?j@B`w{Ks8gPIRGVL6!iJgZp`o5U?gDF7}*dgfcN)@Ig#^*
zHYsS<p93E;{nocmJfxsb1G>@Sqiq1C%Q?XS<>}tJFsZ3Q47r1AD9?kpUC+iy1aCFa
zQ8?cKk|~B8*^x>j`FPO1p#QKAPd)XO??#`I&!Cyhe3mru^beko6xIeca7#`?ydT}M
z4_@si4UmXU0Qv|YV8qM4%oU6Aytn^^tq}6KDL)j=|AjQg)$fhF@x<-5i%V(WAFc<q
zB@5IE#9aUh2B?lpB7vIR%UysjzOw-~C40PH75SeCp)eVm@PxyASN+n}GEXo^Rdpv-
zmgy{jMEcd74thfS0A;~4ox|?a&d?4@Oaf-c_nj>?DUU&<i3%hKWG&D3SPPoo<t8k!
z=-HMs!X(YzJxoIMu7Iu&$G|j$itO&?$D@pMv3FbcFBu43WHa@ZuqWc0ayTlgu$X!Z
zAlMEMc;j|wMlLs8WOIGQ+&>R{9MRCCb4m;bRIYcrCFI~%U^_&i!cW4u!hecaGdY&H
zCCVq_uz(O{FpCH!rDto`ZO~upqZn)Jgj}H_f_HAt)L_SmVm%&;Q6NXq;ctX>CoxLo
zh68*oQ2P%JN(vC{)T;HP;26Bzuh0a{Ts%;b0e+q;K+`TuFu8zj`xQ7O+<xCgaBd+X
zz=J@1{FSys`FqF`^qUT<ce#;64tTA9Pc2x=7h-G$>Q3KcL7+fD+LH#_`u80qe@-PR
z&|6iZ7jH)^4mK-I`;$p~HXa{z8n$NWM8PG(2aov9M-G=xKXOj%*IM--ckj@K_JkEw
zO(LHb<W6zc29k<77#A<?=W%YURJfMluiOE8>N~+ynA&74O(Y!F;*)dT4$ll1d!|gj
zQ}oSyJvR66-gb_V-?Po8jf}G{EuA(<!h8!7u5d2YdkblRU66difcw+{#>J~Ld`FuO
zlRza=G?Lq8P>|kl@BY+jgXg(2Jrq#LOp88_oUtM_GrwWf>j;)O{4g@MK)^`9qwggF
zHZ)IUZYK8NfQHmw_yaoK5oX6P*60&_;>anN9%?;l+(L%dX@s4TU@U8lXzygJ;o81h
zd0?&rHS1UUVI8<{Ya|5t{!SHcAKRvPzM}GmCPxi~+i6r(Lbv;68HRU{NxUUsWiG7(
z26ru(n3#ZkrFo+*^kixnWlQ2QVft87w0F*Vb;b3!#bk2)&0wgw+iq99y^T*VQ|zZ5
z0n4;ueOh+!8s)MUT+hm`><Tvb3&!{MNyeAeW?$+Zj=nLQyf>_k%uXp^N0BB#c{T5H
zSA+^NuO9BY5+}IC$WV`5m-FhGJ_P%*3|p1?HYct+oa_3Ktg?s_SXB9X^fifswLk^#
zR{6Su$Hv3VIqZW<S8V-;UT(L+_9kUqH+_Rg`$L*x4;152$O%;?34+b8$(=VBltj18
zXc)WsD+mcb<__IKl0bvrbhmw}h)uavSy2^~jTXz<0B8o6Uw8``)xzvw0vqM3NOZDY
z1ytP^v!TB6P1X=mo5F?i*!zNvP?u|XgE$GUM;&k8<^&ao!^fr4R~~Cijh7>5R5x|K
z%{>h*HE?nxVzY3KLQB`P_|OLKw+s6jhf?W|lHp-kT0kfpV?6>kWSC{0VBAl)TIHv9
zA0mfXJz3#~llOTX{yz&|lL6iJA4x4OEj#I;5@_8VTpJ8y()co!Jk<~NI5FPLQ6GvJ
z#J9m*i?$GRPJ?eP#qJDn`Jq^;<<Jov`;zDMfKuhm{gVL9PX#_{{U%;jKUbpy;6RO9
zfi(o1x_cX`%*BsnWiZ+Hk7EMrMIPDiK<P{6D7jy}?B*?`2@D!Eq~}fwlzZ3sl<3Z*
zws&*g6jdpGc@ZC94)2q^k2-9JKWgNb0GnM4QVTzM_<kP19rcm3RJ{e)6hIK05%aE)
zg*?*Wa@tx?lb^py&hot@4iaMS^Q<D{?9FmN4uTw0(n*Z2^h4F|J*rkrIbX1F(iHlE
z>|li+@Bd1zYTnh^{7}aM-56%8DG8~E(_A(Sp41G<v%C0|KYe}OCSrs)xvo@GCO(Oo
ze?@Ctg2g#@s2&v@EpZTfc=!AM8+c>7e=o8AcRk!oN|3b6Y~#W-0q9HIlq$d<Yy`QH
ep&S<%J7U>8aU+Oh;J>^;O7hR;@}Iu?@V@}l6~0dZ

literal 0
HcmV?d00001

diff --git a/docs/assets/start-consumer-from-command.png b/docs/assets/start-consumer-from-command.png
new file mode 100644
index 0000000000000000000000000000000000000000..d388a171f0fa223532ccc0a497d237866ee88103
GIT binary patch
literal 6769
zcmbt&c{tnK*KgFR8XDCJML8XHFcw7(X{Dt)Y3o$YL6o#1I6+L2wurW-w#FLkhti71
z6tl#fIz^~TR76@@Q^XXa5|KBYd*A1||J?UJ&;29WYp?0M_S(~D?dP{|SplV$qyYc`
z(E94-y8wVVP(;6wlo0(-H@!P7YQ&Ittt<c^`&4E`oj<%U-Mj<<R3yo4xbGD8rTnit
zAOV1Vfm=VZF)y_c06<B?`tqf}LR{GlMw~PG4LRUdx<Gulb+#eX*ia@Q+wk-ADD9*6
z2ijf(E0$tD?c1M)Yj^zQa4C4_n9*CG{tPkq*r4bumR<&OKHu&}dz|c`e)@8;{2<rM
zU7Mr*GgAAJ&5-fX)cfMx4}%On#-KK&oqTuAxcJt+oLO^<4ddA1Z~O(45uhb3bgqJY
zjv5I7ghWdK?7`;8KM5s)fXA7~7=oi4sGr5ctbSod4%^4ugnl2|cu?tQupn==E4YRw
z9PSIQ!MAd)R6{$&0MxjHN;m-kuqZMv$3|T3|KA<a@IQ!n|9_3Wt@8XVqjCNt%J-OQ
zZ9rML1|zIDrzg?O*%yRw07B_cLYE$yD<sg<Z;kLN7SrwV<oc@{Au=pYXAUAq)hM8B
z&p3}qoDII^+Q6vB(3^wLFlwj2!sml&#iiQ0fp~^vA%R9jIimw!1l%kG6*o5@nZy}H
zMaCdkIDfxfxWaZ;^%0g4B;CTIC2*%P`)~PO8)UkT{O4U57;@fAjJ~rhbm#kf(!kV<
zI(NTKT?B)FnC`mg_JAGDGO`vck@*Rh1QL!4Zc~3<gq2U$g(9jkKQe7@#9*TaT$wmb
zrO@`MK44c||6_wIu#z+KhmacIEsk7<EvB8<k3Ne00@9`8d)p;}zl=fsaNU|PnBv@^
z5z9|SPZC&_P4U#+F>GidPW^g3Kfl@ivoG6frnk3>n+hOknv5|!!0w~$0>tbLc@^DQ
z0PQ6H=rS3(e^B9vN&{ZpaMSVCD__=Tp-#==+BZ83v;Z>XunJ}YR5^^85c#_%dHt&N
zYx@WSsfJ%Yb#>C@tVh?hw|nF&;k5kKRO3CqB@<s(U*TQgg0H;s+L`n325N1!0tX{g
zAbM=mH0q6qiL04euL+wg8I|at4UYmj@Mf<nRv9_hd12W(%!_}RpXtOVa57EPSKhy&
zDF`Mao2a3&)CWhaL6fUrIM8^*LvX#mNX;(v89WpaB?+{*-F)|E47aQt|MI{t-td=R
zyZPj?LMub+9ru2OS`I|vSa0uzn$)q9#;ms*It^K@5>UQoXq0~9K;WfgF<dBfq~>Q+
zj4}#l!aToO(L3QIyD_nm`C#HTl+rcQhh!o!Juo#h40N?B)H#be5@DH&e$DA5cM~V@
zd0#>!vbqVGcj<kW=e?WX;XO1$f6S0ylZYNplf$L#o25B}KZA05OCxYJYfjypUBd7x
zo7oH5O@V~pk?!0R0|*=5$p^I2M|ieyy1tEdF&CT!_jh>|L&%WgIES;9r)0?`tbD4c
zktOk#*k5~<%HM7D_S8wmDErwk-8Lrt3vM9vXT8pH*=sY1az?<9wONV0YNz@)Ck<!)
zp*=D&I86hpBR`4`)*T>tv(=wo`a=6%ci!^Q84J?H@Un8`byxDo66=pQk3A%xN_)*N
z`^iffqC8nAjPzTWtShNJpLor|CnZgl<lxJD9jgYXAyzZl^4;~jSKw77uDf72A&X$x
ztRr8MTWKs!)5txGQG2$+`m@BPz%on=%22XIf<m-Po2!Lkb5Anqp3W1v>nB1%r<5iL
z5F^yNSUXU|Qua%V*r}uXZZ~JzI!;Me`$tv0IO3vFos|4kdlunnxA&DfZS1Q+x8e3n
zz61M@Wr-OKp6_F(eh;xy=`T5zKA~KJn4B>Ms%EWJ{H5Q0UZyi<8viX(*REdvB+J_h
zbU%wyQfYIy#bJsQAHa+BLfRSG1PPL;k;UiIhHp(HAA%UJ=TrqFb01lnn8Wb_;X~ZJ
z`4A6g#7(JgXIA74+oP-`APa9habcRcN-L<|)Lar+tr(c34~-S#PZ($!C=@}DBVErG
zRm5$|_i54s*+CmCphB`(`PO7D@3=VT=ELqiOET`x@)g!m(}Jq>{oWRMd?Mb7WjbN*
zs>l7o!a6pzS}lj1Fu}N!(lW9fTivaB84!G0HovV&eab*u4vKTA&<zI3Q0`443oC6-
zoqPZ*=T^PYg9=g-)m()WGxUe}Sl2vv^IwD>UKu`!c5A=VhW%?eO%dS->Ikct>;-ve
zpLNDh*3Bwi8)1z(bvPH%+U;w_XW?Csv@x0wrfiW}@ulS-KhO$vFsGYUj}DOA>VK)o
z5);LCZ%xfF!~d+D%!#9O1k1`kf485vH!L5ySr)=MI~v$-Ug_4)-_5|u82-QwD?TdT
z%OA(wob=5$kFTjkW<%6M56ke6Lv>%Afa1Cha!c}Jrs9#FXZXiirw_PW?ltg_IHw9F
zdFG+7(jQJWVtfu1K(W|<%M4nCQ**Q6InuAsX4>Y5bER5Wwl^M1U}Ta#v&Add9v7ma
zV_%KO>-cP-!I<Z6TioYy`1v~{R=E9~(OIJ*6d?K7_L}m13wv#tJty&C^lO{>?7PwG
zy=v-)^u!1)LH?&|!OC#3)89y%pbC)&HoQ%8VNN&d79l;enUu1~(G@bLxufB|Leda=
zcM=CqRbvv;=O!qc_^8NHovzG}F;e`8X5Q?ALxN|4VhXD2{C5){%JS|)KCm!5984ZD
z3Zc(wH@M`aq79xj3*w`O@XKr1WDyjOBTrMK$KEmbcw{XpVafjy_~WvzpbTkcS|Ic5
zW|sjCe#*2j@fEwq_n+Vueg*<r!n~9%V~lb|ZvG9CrnyuPeB5swyKer?K>YR<SWD)G
zsWIMnGnDmcbf1f$1-<x$n`VNVeI1Tp7dR;ki0ZXt@Y<jxwQnJ%bV#*v*vG2yhk<%P
zavb>^a&~yFhIdp0#4T*BKHFE&HB@tg=NNYD3wqBrKEFPN|DI#mHu_<y<_uY$ugN8a
zePmL5+ryovUa!AIDp1t%4`8;dy=$}!A3<wIf)vVgc*=@{4sUPFx-EHTH8a85=Q`PA
z?SvX95Enc`yB^`%_dqX6d2{u|)IWad@KdfdVy_W5xChK;-#3I%3DzI0GH8FY!P!wQ
zwM8FMmCf~9Gp0%`yQ_)pLcSx-)Me1mx0;_qyQ7!8=sKKq7Nf0XpME85UMY+?l-UQd
zdZ-*Zzf8zT{1%4aaobXqnJ+O?X%Hv<!Yezv9vtKY0GCDg^!t<gO+sQg^Ydnh^ye7|
z)XXG*o=UCiI)A{oX^1GR)N>f{))UvixQfRd2FQ<AAwI`qnWk_bae$kdJz?Y0DXc{4
z{w?H^7IkmJ=Bx~mDpiC>v*BAT`RIF9*Bi$2EcYqllI;&ynQkn$Z}Gi4KD27u-PDF}
zK8&}BLfGdH&+3cVk2{aTLtL1j<#gW5DS1MdFIS3NC8=&<!}7PDY%O@01B<1j^YK{a
z-ox^q>Z)PW`5pI3yn9<7V=vRDDuZc1E>Sn^PAQ&~1{Sr*nd~)LOT|ZYuKd!*91`iY
z#M>Lx6@xo8o`Oa3wEP+MbZ#Y`xN_oOd+Ox5iz!driD2*zwIY$QO@Z{gvm<Jcxui($
zb}P_KOZ@U_qmD4l$afuSAfZLB-C}N9fw;I89w7FH#B)W}N3HI&{c^TeySKz9Yc1k?
z{>T$<Oo@pUdK_@%2O%Xpcd-T~&Z?xStj~FaSWT3ONxjx$kYMJ!Z5}U$|5F`wXcQxy
z+VZGTXHVignp0OR`jUc3C?<OCX2)*e=5by9(eQ<4uh?xJc}OF<UoNWshA8OMB4jEG
z)VO1d@dPVzNYN9vsD5HAuYk`-s0-)xRWAGgx!pbMfyi$))B?Awn=eUKfwwf|<M50J
zuxG7L`nP(2+E4fU|6~exiRcy;`_+)@#r#&D)t_536%`9{QS<mijI=16e?MArW1o`8
z|8fqG-gfc!MSpqp{8%&Ge2+-GXGgxf)LtbKrDGF~J#iT(qFPM%Dy7NgZ)Jyb8D?*>
z?W$-0|D>o`P9Xf+T#N<PEua^|C%M)eB03N?KN_H{tUSpL`0uZXZ9Bv@rUHS)i))=k
z;n0ZI`q43k@qwYz`{1jK<j+$NLKgX-e9uW{8zWCfM?r)<+Pn>hXZu^w8K;meSk-;K
z=L`|O?(8!toJ~rlivoS@;5cKW6!C-|#~o4MS*f^|g#J_)vAzszT(yp3(sn)lJ**(y
zG_6SZ5=s^nZYT5cmC7&qN6s8v%GLgk)^+7w_Q=Mo&*;ceirdAu2mcwSX#xHj7X<PD
z{B$%{Oig-&L$pulhZl(^@(D=mb^a0g-^+^INlzPajFvdG``XTMjcI}TIaB-mR)v*i
z)>W!H@ZZ6{NR<T=TezLg8jG>hFW;&;#RxSlqGZo(W*EtCdzgIq034;=kN&~N5NfQ5
zis@IHw1x%eA=BjG4NhbuQ(JWcbns=KM~X#M5Ux{gO5DOn8w=bvm2JO<`Jy8W$>1L~
z{eo#zlR?*O%C9ad3Jp(p+sIwZZ%v+x<2yx^KjU}SK(jWDS&E{Bxye(_^)-(D`|anV
zC9z%QWT;!T?-PM}kvvxtc>USdig_Hm%>b1AKQxZK?KS4c#f6zVPH)rS7q=%KAi{(q
zXaD!+@FUpotX;&do$J>6Kk7e@;l`VAc$z2<qi;xNK5H_v3cR&`0rI^Clty*oulMsy
z4k-7vw8l-|!P-?`Vq-n3H^+Qr9z}st>ita5Bxdd19)J1O%$D+XZZ4fpN1D*57)xr-
z{(f@|fA2)m1)Phbhu4mNF3$a1-L-z;k7r(_TJ3tWw~C4+Fd?rgl*VYL4>N+9n*%lU
z=5TWJ%CT?=AntTiBGc3lVItRL2mnkTk-&mBsX3ubFX;7*jWK%tPvU-VXrJJV-x{Sk
zyxn)xXRvurjbdb^;S1A|iH11)#R;XPWBnjagV>ngquJ6?NxADF)K5?<5)-Uuz%}!6
zPuysdZdAZLnvb)z2csBV?Tra$;~o@k4Gbc_oJY-3=E01bJ)i-#;;FDgCmMCN&V-w3
zwovmcph}~1%4f&|te6zxw*!ESUD)`ixuSNeh7w5%-*`%Is+<@LnOPq&Px5m`(($>-
zJwcE=7dHPfLHI4CH7??rhuO$}J9YiQowUME9HUP|CW`p1=UM;afSQnip6^*0TH@<D
zG`c)_FQW^xI{TN8DlV@fJ^0s!>_7EC`7%apTaTsgWK<A*x#+>9boz%FY=ow${_ZsF
zWBP|T-XFCV1|5fnkI%%-hwVRy*rYk2k_dvwxT~-X;_o*onBqaUL;moA^n!l>R`gHj
zMoKFdYduor_U4*Bh{mw7q-frTN#=EQ6WQvIHFAe!fWV1NF@W9Zz(V6L%;MQvwA0Qf
zRyK|5kd0ImBo}95&QtoLH$O$<K<+h6_L(lBEuxCF<wnM9{?dpRWR9PmjVrG?l}xvI
zl6_DjfVA0FMpAt(PhADr$^vts=p&~)pAPaIZSTgvm;h~D*02}OnlIZoGkPv}UPA#J
z))xaSl=1g3pc>GOTTQZTPD3y5djdKUV#{e@cZZf8HFjP@G^XQ<72ozH@w^XmT#ao0
zo~w+-{xe*Pq+Xjeqg#<Af-bpcp@Mt{5eE7x(vb%0zt-Zgh<3HC-W)XJOE5cNg#MW&
zx`)FyX9!L|V)LR<%m8{;G2NGJ$e<!Pqw|_5y^Rr!bU*|rlO9@Y(uEn<DIg^Vb%Wc3
z!>h^;NYg7r_UyC>YwwdzDAbuoOg8j)b189e#`F5s20O!T`_)Q){RlgYe;2llx?YG}
z?!T?svd?A7tLJ%kl)e5c<rlJ)vd)g9C9~ej6pKdZ?*7%1W;jv*lQ-?5!*bG?4Xh}3
z5I7f#j@AGmZs@HJx79d~=8R35j0k9~upD1yk)1QwnwSOtNBi;~(XWv|<idG>p-KHv
zRXu%A{D~n%C?njCBnBv*{pq(h+E=Pw$8XHL_e^yeazAXX(qwNgh<zT#9aWynv*s@4
z-OdhK%~=#5B>&><@~jt~sQW6P{>Lj`nOCASEuGdn?(-sxS7G4}lHN0cNr0_%gEt-}
z`<U=sXP4-!oO68{*LLC}&3mfGv=7)+l;C=yjW-qggJC+G$I;(yXuTCm=(7riuON^x
zv%XXM`t*HW2IWD}nM7q`7k7Bql!nZ~_j5ts=6-o5jq^Eov+e|sUR0}s>)eD%k_%bd
ziKRK9_3(NdKbSM%@z4MkTQ%=D#C)0(jV;iwOBZIuV#7D*Pp=)%Kce7Q_=7h0P9r+2
zhFNTQ3pTvkd96YYE+hVJ(tqiJ(Yy9`hy>={rO4*f?$Ou{+vskKcB7aVOo~e5nY12m
z;43v%{(5yB?malFA#n!j;y&U+{>ukmR}Syh)jvS<GSBrGpi9z<hSR(g(DBB4GP5OS
zV@gh8*=7qx28K;ugRK3NcNQSwq<)Tf;vJXTfy};yE}ao8JU{K54WQ-PGQ_4~MtEjO
zikQ2S&<hvnMwp#emx*2spTN@1wc`q#<UUI$e1r`%d=XzQvwleAR=X>lPksq1?w3!B
z8Q*+Pis!~rXyy+;$qX!k!Oc4C^>sb6`Ayh#hw*&vw<}&$s{%8)$_z4fN3iE8+$RS6
zPj=GBV%`f!9bed~D*U~5Q%(3BwC9b(ZL8FY<cYaZ?J{Fz!f8Q8s9M_+VJ+?<xIKe*
z2C_CDDmvbAso|SMDXGn=1Cgj!vjcgC7&)HPe1LGKjSZilvH{J^C-D1Pu0><*0fmO%
zrHcRLeU=8^QLMfa-SouiO1#T(%5NL#l{}+0(RH5`oc~4`^xlIcE(_E(E#jn~Jy_0L
z_sKOY__WXszo(^|j8tYj2$W0xo(JG77OG@{)Ya8^czQY2uT+03s7N=3GWekf?b{dl
zq%0-TCQpsiu!~JxWeq>O(j-mbnwCuA`rp#<k&N9vV66r6BJU3XE^VP<KWRxg-<HV#
zHAoHqH7&Z*P!t!;FXnH0vc`Hsb@MlF=Ve#_Xebu(Y4#*jbx=VfOnAG+z?VDqkpD`-
zyKI~mXL`r<9~(7OHT|v&TzgIZVfHNA(&CP1d?#f9Cfg87ne>luQ$O91$y$A<@yFo!
z`yB5(Z-da+Usx49Q&!jSsPV)I6nSbd2%??a2>FtT!jVqOvo1JvLiJr>u;_qyJ8`be
z`Zm!P=y}w5$kth$p=3SM%e!w>8{iXh*bA;PL2nvdnMizO2)a+l=yv(Legg>{{peSx
zio$QX;PaY{#~NyRI|25-YuOER!CdZWUyRltD(JqPG2&zmh4g)Xfg8F}q>PwipPgR;
z)d(}_W)z6j5h%xMV*+ugN|OEJ`JMc8VJdz<Lyx2pk`GEW$ie8(e7i`pm8AD93kzc}
zg_ogAV;BWjMEVts<i4e)jQsqs2!{(}c8(#F{AqR!EA_y-z|?B_!UK9%&D=Oh^D$W(
z=z9N;HBXZX1;nJ0_)>S<vsFUjDM;zS*ZkJf#KF6V_=>)rZ6?>c3S9Hnmr{|XP=Wcc
zdK-e+F-Sqwg2K0O@Ub`Iq}~R^`p7&v#qWBOCSDxS@*->{v~~+@g!3y+)~l}11BC`B
zgnBZKq#zqCIu}V=p|?|XNB{O~3Tt&)OcGFxBdiEPk40~(0GVz{t(LF$Hh}V65C7qC
zvaf*r5Vi3B^Zeu(a1ANk)n-L$WS`V%ikLl(8c$X3<y7t2t(q@pbbA7GM(k@v8o;g0
zjECb-LK(D#L_|Z`$y3f4!3%mAx>!n@HaauU{JU-~kJ7MTPj=f3#-KU>z9z*z7QuKl
zf)_zzyB@vy9#-vWFUmxZ2fqjZKOe>?mHxZb_zcEk?P>eB0bjh_zqn6??dpV^l&z}5
z-hUeu1MVSZfVxH<{ofr9?+~%e?L7plU@&e$YWu<c=^L!XVHFQi?bA9dClWvI+$SEj
z8^{OlcGcDYWTT9e-S(xiY>RypD<OCoHFQLz1&BLAUC`C((a`VsE;ndxT4AI4TG;Kg
zC5Z*orq1bf^#2Lp5SIex?grZVm$z+~Ozp?uL0e_nO9RqDX>3M*tF-I|(=8MG-IZRn
zC#}ibe3d0(a>A#s38|ovQx#h^9l#BP8*xe|G~#9+l;PW3>MHxccPEEbioY7VvnA%Z
z4^1~D(t?Px;uF&Ot%JbX{g!syMWl*ssn=Q{S{vL_Xt^Z_x7(`d02(Jt-=!M}^<Rrp
zqW%h(xHUi{6}w)onJ|o!1MC@Y|5l#tW$h9`WunC3WVej$Z`j==L89_6Rb3DT^?2w9
zX?a{2tSY>Z=3z{Gc<Ijs=Y`-p>QaVwsTT;gKXxl}+)1?^5vP6+lg-cXRXZBdUp~_D
zXuAZ(84KUHkwKdQdU7|~cFC%l;*f6j+en<6A`EoPw2{aD28>5N3%aFIz#kQgAMkX0
Vd*M~tt*t<;uiU!)(ZcQNe*wVG9f$w`

literal 0
HcmV?d00001

diff --git a/docs/assets/start-consumer-from-explorer.png b/docs/assets/start-consumer-from-explorer.png
new file mode 100644
index 0000000000000000000000000000000000000000..f037ed89d1779eae5723378328562c987885938e
GIT binary patch
literal 17189
zcmc({XH-*Rv?d%YVneAa0*a8(5k!a(!Gd5Yq4%Z~F+#x5dsI{)p$MS}1W<YjgpML4
zDhUV?P(nvUgNQUS^cI){dhgu%e$8Dov%ViLS0Lv-``u^1dq4Zx&mqbXp?&1wse>R8
z=m`9#rZEV#8vz3Cx_n?i@Dn!23<vPvE^lM)YoM}@(-Xjly{=dFuYy1oafdc;?*l$_
z-oI((4FYldZ2#N!^^QmY2z0F;u6floz<#FDfhaZ}SWs8@I>~txB0d#|vg(cXs1!>f
zmy4O~YRM*Eu}*(f`R(H;F@Eq3v^#n)Zeh^1P+UBI_YI>{4<Qk{tVe2=-%lUNKK^-E
zgzhWU9WV5=FYaCy0)l(5K00&%f!KjZdpQj!9DFIEUxU_5Cnw8(GlqLQcM1FSEswLw
z#bul1@eqghRLq|t3VUeVT+qj#A|caG6mt;hE%OVyMF>=W?hLSFq1OEtpkI(k9?%u-
z%6ELAHBRPU(5HC!`}-b*J%a86`G^VH?s}2+f8(n*bkf#Z3(g>H&V&Y0XK_WeP}Gw!
z*3RM5pamW(C+Oblv@51AV6n%7(V+j9Ix#)aDL`4YaedlCiBGn<IPmQth`krR`+@au
z%GM!T@N8qsPt<NOqOZ(OS~&1WR?^&pAce)Mo|gL0Ep=C>G8d+<Us`Kt@?@<zOX_e#
z7L7IrvO-H>=3(~!7ysw22b9oV_Y#~ZI@D(6$eW8enj48-O{Kyc{=8qNZ;WiTkLWlN
zAN_|{uE?f~A*^q7-RsI?517z~JRM3tB#b+3O=ZPo1+GQVNbJE0*!j#OWuQ+62z>&%
zcFPaFFtctqI7*ZDq}VkyZoSeKoO|Mm%elQK9rwCAVIAih_jJt6^}P{mT7cLQ#=2;+
zIX|MV+Uh?s*)pWv$)Dwqyb$QFQLU!QmSeb9$9FG|D~H;_M%{iqmrAFS5>GmG>YSXi
zNfyxH>PITyAS`^U%Y~P~!8b9B78o<w{Kq=o__?m!9xz*44K)_JF`9LAR5pEQKb2tg
zDYzl{u+(zfrs4j4@E@ZL<jYgsw4%hQ;+y(yLNfxS)B1G8IjqGwn>?{q@|{qYZ%d`)
zxREqs)T^hV0=5=#foZVVav@2DyQW&B9Pf^WB7+fJnDjI7=VHcL8$VhvAQGe+`}i}c
z@ZEVq1uWNtJCW9EO-1S`gYPnXHOu-WRAgyIAz8S1^OxNbUKgcMl&AaAiUTJWrH{YQ
zEnB=k>y0iJpchR&qmrluT|%?8@4T&Gf6xMi1BiyrL~W7K>cj+@&R6TdF@$D2{-84W
zwOq`l@qH7cB3tdPlw!Q;gxOGFt!f@$(a35>XJ%WmiSn!6S2Qm9qVEx&i|-n3K)$?t
z4v~8QWU)qv?&FvCKc6aL8J5b4SxM<<l^Nrga^ZeYP0P+Q_X-6r_FyhqwOT!fWHlrL
z_p-jaR<O134jya`S3IeR?rOuck3hyIPC}A;l)wIpbNX44a^vs4?9ivMy7&i$dTgCG
z8MNxDW>RaNB0hjo(e0N5ZM^)^-*o6Cjh^YBrW%KKD7BSBL>=z=*;47^ka0L^#%$eQ
z+U%t#D81Ya!m1d5z99cgOeYzF#&SJWNpj%ZIUYYuX%jOqp*@I?XzncQ%ZiuK&(B9g
zLZVDEHZ-rMy1BR{e|SaKkFt?eEbIKfks^vv4}%pHO`V#z9d7o1Z0F3NA;t81T%R9<
zfGouewxUfgeKw$*NGgVLtAIt%yV2lY=lP#Yo;`IrLP>}+HraMKKJ})hxrf%UDIv|-
z^(Naq1M~IXM?G|9!{?gx$wSjh>C%Wru8^sR_b<a@p}XEnS<;)npM%fg17mo_d4j8;
z69Hmee7g$cQ%tQD(|#1V5ABtSkGnxFny_`Uk0v=`P&PQcP+cOtpHulNVIdlSxk_x|
zt^cq{T{UGfm!rvSDGDN&Y!hfT;F7R&+ImG1ez4R(ZV-QYP86**)}XETU;;k2Qo}^r
zj4@Um7$tFI)$%6c>0|E`3in7|onm2Qw)aS=ObZ><b<FL${=MkAEgeMYDl3kZ*dns^
z>c@oh7<{V@QKDa~>XMM>BjU-olQi%(Q4G!9PkEN<N4mTe<2%nHvTXxT)~?RQ6^ojD
zcXo5jhaRDuomiTvoD@qiYOY-1XYx8_*%nO5HcPhZjJ`3et9Y<_0?$`uTFiYZJi~>D
z3cvfNV~eiZiqE~dTimLvWV2>?jGiN_s<38buptCI54i#`0#qIfoUR!2jAG1QlV2yn
ztqJyQOp_yK3U1?X)!>5P@d5Dg3U6S(c=cckie$kC)`69%H<6n+^J^y&CTW^Gk$9B=
zy5;r^h8#jTF67Cx@x}><OSJ|tRoN8f%$|R-w4G{8ukUu*f@HiLW$=T~{a-5t|8L66
z|Iw-o+Jp|6al^vT7b`Rz=Gk~3dbJ#?t}e4w*<e-?tGw%$%iqVI8ObQXLhMC&Tl$V-
zwL6?wkDNicjeQN)uxQwrqtlwWG!lNw<KFzPe-p5|DuC5ZAzKNTT&^iuavET~?FhzT
zDAY9<ON{JRsw>&9)nZF_wk=7TwudVuFM%|tzglj)lNsUi)QOLM4)Xh3`mo^<8c9D@
z9zkVOE_IfYn7Mx0(<dtA{f;!iipqN8#>B5mc`D|5v%GShMBIAD4@UC5m8&?7R()e(
z8#+3`#L1cmcfdA`(JO-t+JKm+LWcmytgt|MxHk3za`W)9g0V-?q{0kUwDHg+ZY?nn
z{=hzj#gRl_-IOX5I2WIH((iW(x%rLWPSjY%LNfw$p|AXGZ87stm?cN%#E@%ai=)gz
z1O7z9<EoM15~y&4J?yg=&SUmh0JK7|iBmn}*D|&Vo_cmxn0Gvcopag3JbDbZwINnI
z*zp4T>RVeK@<J~fMHmu!<#jfeCg;%N(#$4xdygx9e}7e>JjCcyCw@tKoSzg!((sLC
zI5Wl2pAKSC7jLv4<9^~UT`bp#AS~QNxrmO9a*i0_kbyy%kx*A@<a@EUj&pb^dEI+W
zZPw(jq^(caxsn3OBBD5?rG}G`rSML^bPlxfz3>Amrr(Ei*t{RuwNP;(1zXbeJR(IS
zW1OQcYWPr-Chx{x4esYnbidP+E?qobZFBajZ6T0r3eB%X>>IRPLNv6P+11Fa-WAP@
zh(Z5r{9RHrNuhr#l|4L-$8*_ub#XNFb^94C-oEkA0ePVTRydcsWwHg)Gjys5e!2B=
z(uKf3Oy|ncd3|+eg`wbN`l4B&`qp+@TU=1bM$h6Vhl1%A?sgoFcetIIxglc%fhW|-
z1_J7SAH&C<?Hu^z^=OkASgB^()5H?}fi`$^;)!TZp3v7)CRWIk#zi*g%*_jA1Zm%$
zYw}@7QHUt>G~pY~2iS0`OLbRb?vtKuEGSBc*uXwffP<zIH6{Oaonb1Q3z6NUGdR<_
z+<RInbs^vLz&t0KQg9Oajy85v>5GsOH{WhjzklN-l&7GdpZN4Ime`1B3Wv#Rr)`ch
zSF^aB8vH(A7F@Jst-WC1Gr9EAH6aQ9(NHu0QhZslE!>uQ&)A%TAZT4<-f+K`*Ljr;
zR?<y<o{(NtUBN3J8q1EJkvAc11UocSuT5}2&^vY*e_#k~0;9E4Tjz*n1|@FVE;4qr
zp@L*vutsLTL8-Z9SxrV1zBMP-tT`)ZvPHG`X~qR&>|e`5(A;1HPqrgcT7T=ihzM`r
zQ=ZkDtZ4A>3nTT`wjw~-o@(ncj(_${n2NMU><%-NY%X<cF+qBJQzd7b9y5+Z<T<o>
z3slb<+1o}Tt<h=X2rD%yo+mmk;^)aBCK?yI`^GcZJ2XEy3i|dn8wUG%TvOPndC>E>
zE}5T0I7%2;d_BcWv1BfN8Tg(X(zsEzhhhO+|7n;Vrqm+xMh3DlQCjcC^ydi$pJWgs
zn-lN$pg4mb*_zh<KosWpMVh#Ko<$eWHgT2+6iBF$qv7Exf)34-QX^gUktTL(zSnZS
z?A<5ZdR|ucs*HHjEil=7Co5)%>cr%~9#BPFbB=2GTsm>s<$Eb}wbR*U@`V0I5}cfP
zlp^GtV9xirk$GO{$=>h3%AtgW$GI72gPSVxUPf}2%5+8hx6SB?F@*Wkgj#;y0;9(A
zNu}w&@3{uDG)e52!%DByp%a!Qbe^X1ZEnZiKk}%;M?2e6H$F-OPP%t}HOOq!#Ne_S
zxfv!@A|$WM>d%3Vr1aMc4PBh0R$iN(fqnP+u+xXwfDzZ*FmRQ`Cn{O8VGz3K4^4F)
zrSFhzw5X{Tcy~@j<-A$ir;cYx$+Vt3AF?9pUl%T|c;T@46LgcW5y?!YT-(O9;w&B-
z{8!^;3QyhJ$E}aX(tRvt^5Eo!FP+)j_N0F58CxY6>dPY(%JOXNj?)8<8>`)ur}K~<
zGKoT#NB?Gqbt=-em9`JmYw)jP*6ycr-ZJ^uTQGVbKzF%I{p(2vPaT6i&=>#zu|QVZ
zqgCgNn0m=aLFG68ma2<b#${SwNjP(@a|v68+{}NEsXYWT`wP8;EC?OycD6#N<t;Mh
zPV<J3jxt}pzg>}%WOo4Q#ESo}u&6Prlw9zxry%8=K_2u7HvA9-8LWLhFlhM&bet}G
z80ZxLEq4cYnyeS7Lq#Um63rn0bA|R}kP4Z=HtNLOZQnN?ZMMB`U)qMGk4g`PoHZ9k
zjA47rr@xQky^@og%Qq8AO(8Z%q}RtLWl>3oLFVuszYm<=KDQikW2>m=+y(Im0*g`)
z=<wpvK`s}OGAfY85~hy_=6u2#X^q^({G7&Cmc-L3JSSfMLQm&yHEp08D*w%q%6bGj
zev*TlTp0x|+39)Rw&wW7N2c*bXHDMY^RpruH`CtVGd`*2ap<X8v4n9pQJ@QSOZsn2
z3Rat`B<H_;LA+Dak(ZaCn2;`EB3`T!Ppa74n0^zV6vI@`mqHkoeOa;>^#ql_{_DIW
zfzS|mm)NP?yP|Ts#|lPYLS0JCdnzw>M=~POA$t$ra{Igblt6)t4&Ks|@N=ZNswWQ%
z>!Fr?l0Y~OChmF=b7m)`h!%w3Aw;NUzEYH)tqvy|>FZ^ZulA0+!XvR<GO&`bXtJ2`
zH6H&$5Bn4)f~dg(k-6t@5XUfm3@VoA#dU%6Veq==;%#f=dlpafC$$4PnM%$J&sNIa
zEt6EE;#)0yAr2hK-TnOk86GPJVY^;%{M}1?0Q5BI7Vba$>i_3d!T&avtCmRN!i|nz
zMc+T$y5~WL=#IY@bO}1Cm&#nqG3unc0|2!V{nv7~9lHL$;o)O~An3lo`<%cs1{#@@
zf}Q*hF#L~w{{<<L_<-vO+&gak;X|AFc#ih2W|X;>F3;<LdIo_r<Vhj|ePMGq(co6k
z8>P@0zKA5*2Fsrz=s&;j+RT30e4C^uvlK$`Dv`^*NQ)hc)DA8a2DxAOyWm3I<ed*d
z%#{gHHg0nuxl^G@$nRDK6`xMq*Ls~p8>h+F`R6J@bc_fI{o_kq+A{`=E)tfJJXbvb
z1x;Xckyd6hSYPybfpHl3?V|iR8nXDy-HS+3%d3P*$CTU>6VNAtznfeWKFT#$ZHnYJ
zVJdNF<CDZAs6U6pnFMJSw)~%KK{uYBa(uJ#3cC-){ugcrgvYH68;WI_QdA5#Wc0^L
ziM<D3X#C3wK&owHB-QPw$tO$dXOEf>C-zeVZm*Z3OXLjIebkR%1oiv<yDtrCCdO3K
zIb>{l@Y6z@>Dt>@DH&%FR@1Fb-<vAKE*?bh{w44?PV1=11a<D5<E)n`8}wlM0aG|{
zh6F;i8ECo&#DqXWS9fy31PLmu*KRHZx^iUavc2fE-9VGF`qw9s3|`=oeboM!uJf+|
zJ&yX0CI1adt96h%@sLCKCSw<<HfE=6{udH#L5r~2H>AGJ8J<^3J=6198r{~l3uLYj
z-16<jeY$KNugaJE*ICk(Iq3_pS<Qkt8_&iXV-fUj5Y%Pc5_3ALZrB`a2)<eMY9c=!
zJLE}ej1C9-;*R@UYzGPZ(8ZpE@{|oP^z!f)RF)#Ob4`SKjN;iej#6Vd8R+c#PXga^
zNQSNc$m8@RuijZr``7!IT($8|Js_*20mNzn_JURY9>BdC*6{kR&2@-vV^Gb?Z-0u~
zg_)1{54SR9aoc+v^PX>4DVSsITMZwnPp9!m{;vfivYo%+Gv;(iNOj7OT~}<X6BfP(
z&$h?ZE>s54w-4H_*Ec;BSrgcetE5`rl$x1=SiXWP0|5(;mYBK6(0AKS%`2}loeBy?
z<NNBkgT(Lpso&KbqLzXwa-kR61v+8#Gjo^HgJ;>cX_&!Z8@@uqVJq=U8rR3ak#g>;
zjx#j5#ZI=(!BBMB@EvO_q>$WT#M9c{Rq7{(=A#*wnfooW5MxMtbkJNYq~Oz)^gLXB
zgN$<Z_?OKW&@iA#rTl2e<^H4zU<{A*b6yb$OpuY#N``bN51I~HZPpuY>4*H}gUIWs
z8nk``f4~c5Q&w;knT{-qVaQSy#YX+aZw64;XS9c0ahvqlwVG&deH;Iw#rpx_uy$$0
zDd&rYL3*){^<D1Amin(8!ByQuPf95d$soAJTRUdAHU$K%(bxo~DQg11edP4JKUT;R
z@OFL@EI6w#$^$W~^R2UEirxExtfC=-64S4NN$}h0I@MoR#;AN9^j?ifk@cj0{alEU
z6vlf+&@!bj;1rv4e*=Bf`3~uIWg%%DM9s{nmO~u07tyaRPS-0!`fjbAHgIf#_0{d4
zq{8RUAj@T?Z630QkmkR)TMClK+UK}7OLOy^r$b=h=Vde7Xl8Pp5%N>w&21WMzjA2O
zqz2=;#@WjnMI;NM78q@X6^DVD3=+wn-ux-@8h9+eYsQjAG<eUn2{!*a7dkBW>&=Qk
zX4!viJv`h3lF*%4dyo0{AZYlRQVlyN*{+BOa?WEIl?CO*7lgNfkv8H8o}%)Nm$rIT
zq|7P%+_pJ0mf}PzcYJcEQEGsGmyT7Xdd!+(Qq8@=Zk^As;_#}Yqu2*#gD2ukp)_*F
zkcO=#ArbuYbIG$4R+-Mt=7xHadSS$9Fox2`1n8boEI#Vl-fO=a<6c$<A=(@Z8w7A8
z?BQUX$mXAju^%L-yx@tIwZ1Hg(arB7>W0aTk};R(A2vRVTqgW<ExhdJK&|D~ZJBiY
zShwVZ=*`cQy`HJQwYrW2NOX$qh;9Oz6$5e2FFmDExciDqb(^<!m)M;s{HNZGMNeJY
zgd=NhyF>^=_N<#nnY3eLKWK{T%8!XAyG7c(OiZ&Z8*H&95@W^g1@RRcL$IdsS4Xes
zcly`s*@%hR6BLoGo3?uQ^&-U-$a)rN<JS^S=FMW)9?f;>$|rHpeU1wwYVvG3Y>wHl
z+LKgk8v<X?cf7&QhK#?VUFTvOrDeTT#?0Zf^bA93M)r2Fse&<^ts_ZW@3_JYFLmBn
zX&hM(VX0u|RmRrY?5*k*h6cO&W3^e%NbIf`YV=J(eH1`{zOVgVd%wg(M!$)(o^GDu
zEaAvZG)hUKWrEw@{(4pKsB~>EUg!F=49SY)R|z_jk`|%OmaCNnU4Okn#9+zKF#wM7
zjupp1kEAZhx7l5&O&G1CW*>k%hlKG$ctmqbpsUNt@}>^b=MxUMKGhr*Vdtnpcvt}A
zVhmfK_I61V_AyT%+1gyjb%y+`qG_woeSU2ijbX`W%8oj(p2Td9Z#7JZf5oiQw{m%f
zOGxU4@{=Z-i^R(%o)R7Yl=a3Z9q+uCrf2zP8|D$Kn{7#1i6xO$T|k1~1$rBDGfn-^
zL#}EtKK;gBX+(4K<<ptE_~#Y`L`uC`BCGbxF}h7Yv?trEwb(q#C`(&f>-H1L1@Sx_
zbhY8qUa2zZ4Y4a}Ut}HTyiPF_O9POHbh*!>*YFyvjG_<_=y|*1-eL-~`;5M$8V&h4
zB|<emaw3B&nUscXQ|<wJIhW2W`;yNf&RJJq%!d;c-(5O_Hohe9_Oy1~U7D`p56oz0
ztePiHfb`wbf(_q~<OYt)_2Vp2!=wn7RANfD@wMW)PjEsrJL-L<Kkrnrd=vTT5SD3N
zD>7INqYfJr^4DQ9-bw|zF-UF*Jla{yILC?Sg)-CGCFHU^q9T*zG!wMiwWm8Me}ZfC
z8y6jwNeZ1|!G%Gf>T&ig2ICqy`4T#8GR<zVN~6|BF@B_;QK(@mCKqrrO0Ex6;n8EQ
zHTcp<mq(`U-g>R}htP9u2~v{}W$-5cE;oc;=lViS&3YnL9FgqNsoN8kKr;<Xl*L1m
zK2ww!S;w9!A!{biiLBmawO}@WiSYw><v<rZO>N;v;tyBzfqrS6L$2LredogDuJkyt
z?^^?7xU_g^D$FH;@iYu;a!A>RFzBiB&f^<x;=0IMPxWCCNNJwD+{lHtPSocw7~s0n
zRE8EshzMgD5nYNP(5GmDf*WI;=)o(48vc9VJc`2CPN=V31zM9^$Bz{pb+3f((ge!s
zgWqQmLRSd4(gCypst<?yg3ymp0H^@{I?C+cMdhsJ1g?0Y7HPt94AKw&zi~ki`lksk
zRc81h^qum<?ExDHTIY4aD<5A&+pPh6v~s)1-`}7#f`fx;i&K5L77+}refE$l<=w4M
z>+_Fi_M(eNrx~=Kcjz40SwvOfw}&KNi!xiurR8M^Y-{5X&CY)~BiUiE+h|vwXZ|X4
zn`+!)CmWZ;<k~e*KAZJNximIz0vW^mPoI%ehPN}GHu2}rHsP7cOtM&F%%wke22Z`I
z_~`vh3Q=6J=GnN|M=Q`^r&dRQ8m~ZHy-v7=ze-3uL1%oMWE8<r_0WtVfD+xN_!1g!
zq^jiq?-ku!Hi3gaXm0fxU57QVOMwR)mjlz=@(oscDgIvr3u@#1hR69JC6L$jx$)ca
zQ-ywJt~S5<`t6SuSSfwrVJfBT5$dt+$~e3xymEe>vPFAhPRJH(ujkK1@jzah9WRY_
z4ov?b%Cm`dWb^p;nMym?|J3(N0^D2n09x}>EAuB`0VFHL3%fqMbuCS9a;~yJKHR@4
z`C&>1P*LBG3q5)G+pAw$a=ufgh4>Od5aUYNKU7)CcY=~}CxJ!f5ui5!j1MA@_zb!d
z@P6C|mV_&@<v!}rs~eq!S@^6CStW-}*NsU&tv%ujPw!bqb!5jtY4dd}!0s#p*}#|)
z(x#ds?~vI&uoo!SR8AwFU>QM(b;&%C@%4XO3}qU#pWi_fzxI)pv94o-9(6tXD_}l;
z`LdtS&lC%dX!Ni|pS8Xt_6tvCmEou#T8{T}(c{oQ!&QFW^13RC`LHA-E8Vz0+ZAtf
zs~S?++EO}mC5#gj6XO1PscLWG9`rq2E90FLzB-UL(PQBt3&6X^gJ5k1J7gPf0vk{3
zxM>lggFMB{As~a2(F7ZqtOnCw@|3s`p_2O7axBg&RKnm7q8`8>2<$oT@(vi(wD3WA
z&T``5IH3G;3*%nSkx_2fCsfVrNhEJWTZ~6?O2uI`7A2V+J7c{b!UNI2>A;@ER9=)u
zT;s{l(!9v3IS$cJFz=w>(3|He>Y3*u>Gz|+U;4Rpaf_uw_(MF&(25cgSzbz`#B(h=
zbX|BvgBClUyE57G<d8r<6+SjIXk}G{a+wYqymXS(xHOnc@yk??UHjJA%3SGpG$#b0
z9)B&#6q3$lHmmRcxQE%DTqS_(BOSpA290)!p#*8j*}G85=`2#BVCi`w{$N(<H4AiG
zE-j~ZWUuyYRZn^ulXqWJO2w-n5&Fu8gu;AfA#}AzOig60hgKDq2EDx4&9JF4gD9=8
z!fkm_G9@sc-9oPTyM!0A?Ic^xlZDb2+S3t*YARWoQ4b6q_&ULB0rtKXQ-9bd!~g^~
zZy}(4@svd&v9n%TH8!-g$$?(4O3qRr#)tZC4mwlS_sHyKcJIgM=S)({ht$zJwL{?N
zG8u`f+{ClENRtf<Un8i}!1_kuUTuJR+iV;=)Z-~N${==HZ4JISfprP>2v52ArfieY
zBY+W#p{HaOx%Z&bp)|ND-d;wK?hF`ux2n3nwXQu^#!<sPJJ#_`;vH0<{x5~$<s3;r
zAu^_d+@%-$SOAigDttl9a>P`-qH6Qk{G9J}Lufj=VYa}4gv)_pP$5E7DI@{Xg}1OX
zh^oSPa78K8C*ZZUoGS@>noH6CMg4X)-D9ub(C~|0Ol|E`2^k_cjP>Qg5tRY@5>Fki
zvWC9V;44!+q^r*9G&oOo)|rbFXA#3RcuTQcpE1f(4J$%xT`L|v++*ZEBGS`$FmtP6
z<Dx~FAUcgtyJd55Me$S<(SQ}Sd)r}};Yv|~G`J$K0=lh`PIq*5PRJ>(FN%047^#pf
ziAenx5Xf@;Hg$s))%A?F*u?;s$<NL^rF|Gorzuif9VOZ+%f8Vlz5;i}Se|@C@`z(e
zx~5a3GM-d8<sgPw$u281Af<nDYUrob_xn-<?k%^gjL3`@hvG^sfXZwCbh0qo(Q1(B
zRu(XDL0fexYg{xdqbq5agiPLlUOv)9$Y0(3w9?HTD3UQ9n8%_#FCnVhK_!l&%#hD#
z=kqm@%@+*g!DuYLk@HzA9RJM{8297w8nM1aJ9&r6g30F_ROOJt(B%x-%%I64cqU13
zwEK4GpHS0`dN=WGC}&UI_}h(Odf)XaRb}+r<}$@$Q}QwD7)1Z^K&=kJ9rfNm8CujX
z(>~~SZASZD`R3ZZq0ERw`lqU%_<jM5z14IrSA<R4q)tM}VcIe?aq)&TmwU_n$F-@^
zU*5|u3&o@PofmL9)d3zXvhhe|@WETc#|jdIv5i?Oy7>M8^jxQserqSRks4+AG2Pm(
zILfL?=A<F{@*eT;pENz+iyk+$Cb~K1s&YrE8dW}TixYKbW-E#w)Rqxph$&dvH5TiO
zNH+~GhxV@b=R<fPIH$$wh9mgvJO!R1qk^=otyPVY4;tEruV<gGL@7G*yhy5ws`1FK
zQAIQ3kmd$+-`BH!N*J2Tfj0Hvpb^&*6?|;g=0d?(NfM6T-XYx_>kG5m;-%{v+odgj
z9z1SzrCWnu<@Qs<1`|t;BS){fj!z6_L1OLBy<9f$oIHd0w2xYJbQA9YbrHL46rD`V
z_v}F(Onpw+4;I(^1xn}I0S?Kn4jVLw4%;GYUTTrhHZidqJqcp&9RlL<D1a&MJp79_
z9PwMEdi`AhjbZiQMk3RRP+7tMFGf*BuW@bW-~a@~9h3fFaEr&?FAV_a0PcDWZ3hUE
zp}pHWpCd8pDkCA@QIGed(*Oz1U$i55N=011?rV@+>k*YN&#)abKocwr+QvjroAr4L
zhCJSs{%98T)N?5Sz|pNkJILuJnt@}?)Q#A0ON++54O0Jf1K`Ge7qIawDoP%Am`Wr7
ztAK0(5A594mnoK*5@oO#?KLeVB+$}gc2wSie&ri5@;lHMJyjdBjkExZ-MJxXfL6(!
z8@)=P2F!_UXXe%Zv8D;7=jXZGw^_d*=;7p}{}!#H7RA6&wa|=V=`u3QokhC<xBvFB
zNuDo)blHxeKc|SGB1ur^C(a%nGhEnFe=e*yTv$eg%K3uQu++EZ!oqAgZ27Z3Eq}c^
z|Hf-Xg~YoxI<n<SqpXs)?9wRGfIa6B*IX1ixzlA4uELT>%Y+2_MnYb$+zW@n)4~GT
zuU;+Tfx#*~>}eDuWcT?5B3`!W)u0y{8sJ~;Wj3&cV~sBLieXGObZn=cPOjf2bv568
z;%Z7sOQxP0$LZL(P@aza46ONEPQR{)d_0%#r@sUaRV%WXnKi{&+jEuPk6E*3hvauq
zWX1;t?VEHq_g76Y7e+Rhx4ge&%r9|%)SXTbQ!;XK`R>S?7TgMCZEaAt90Fq&?6dOh
ztGtq3dAx_?hPn9FHmfr}v0Y!omn|*Uzz9{5(2jx7Duj|pEg!@PVgT&U@hL1OcOr;I
z7pYAFD{w>7yKUU1U4{Zjqo6zw@ztN5!;Iy1TFN^<?`HmRf}SnRH=}vzK%2*vikz;E
z)1CD+#aq+gm%$T1R{RJEOs#L8DQjt6eWOmZ9IKdZDi5U=T~I#bc5QxQi$-BD<Kb7r
zYuXBl@>K`0MV$FDEB#_ZkV8Ggiz5wFkvznd9LrisgXQZD5KWT|D~U`>9FwKYP(gFk
zH@?arib<c3#2da|iBME=AZW(GWTo`q<4g$8FSsWaTnd%pd}-^Fot5_XvUj9OUJP;A
z$l9zwf2fptir)Nj>a0<e*Tpio-70+-i}XGHFDt?cQYtCaDB*M|L>g#o6SJiu$g$ya
z^aYBB6n^)JhdDkVrm7!E=P#I^w^ix|cWI*ssk1Md+kxs*NJuG|IR-iYqX?%IwQ5e7
z<7~(kJs#L#8Y1O&yPD^TD!RB<uq(SiK#FM!@r^ynozUvs0G7hrFIRH$zZqUEoG}m&
z<<%WeuYL0!=uQS|5g)7G4Q>TI?4nL$LJpS%vni{yV1>=$tv{4R(q@5&VWxJk`-8fy
zSF~>sp^@<uBV|w6mgJte(3nuAfj_9i=$^VP_c@caEfy;E)`n}}7HWW!&pFufIkvQn
zB8-}whB*eAWPthkAX5>a;_Tk6q_%V#7s_sp(y5)A8m#$Jx1qUdZT2VEoW5!AidyEl
zFbUqk5wd#Xy07>L)}R$8)H*snqhO1*YSrMIjrKl{=9Y59xP$~#;m=`>i#SA=m=-e;
zep5^RVTugU_#(h_5+_S|3QkJP0q)d#-OdYfYPj*rWp@ow8wTD^a!fuKfq;+nr^!rP
zhL;NP3;xQXI`iDk^~i2Dbg%hNm#PgT9>I+>h$80lOS-;dp+Plk6`id5{=Lp)3->hC
zW$p1NS~^-M`zz$}@rx$DzV_rs<v?GaJ3!F<f|*(LS+`&{rU=Z7d;^zxor+{J8A%>l
z1wG5-1zs%mw!zwk>G`>F{-`Xpp2=lYoJ}UJy4Fm~r4%DIqD63gqu}w;qF!T!I5MR<
z`ZJp;rk7c(OQ0HNmNi_I2>X0B?Qs<2u2+WaA>T(mTHIdfQ+OiQIpMPvAwRQJ2Vfhn
zPnNa#d=2T#P5b&gs5{EUL_|;nf5e#~a<p!jnT9e{5VgM(nmTZ0mV-sKecFSPa-v3w
z>XN2#8uA&GH9m-_QD0VooufmgpKN;>I-T=8!q3;aBCVrDQa%&+veGZBKQ6ZF#7R}p
zbyi>5(Z#dLCei&W7`dw76)UfM@?25telq%nvUw$_EDvfBwy57vMAI=0=HWe3Ejc>k
z`caj{&>FoXfL5$EAS6>Y2~QL8cfov3oPmnS6yxJymgK~}vz$%P2onVam~G@h*qgX&
zW@M>HXkL7Di!h`Co7g(dRI+*v|B({|)t_9SKjGlCb*cKbus#xR*)&@83O=Heq%Q!u
z9!>;b)41KOuVmi4)$eSkqVO@TThnehGKuae*}i5gAfK56KE|d-<(6d-$)xleK}Mz9
zT@8L+m&#Vv1pP#P-}E`=>l6CEk2~mFmeJGJzk)gv%7`MW9bq!bpL`3`r_Dx|n<5u0
zYuTZE3}3sny-juLi$=42O<R_$0c=yhWL`;9dt;uWZ`SqR&h4PJVk&iFK6mM&rA`_Q
zj_rk=B|7RQajpVdMEz*^rlAZ|j8X`Viieqv8qAGz7aTuV!KolUZVEv#orl~tdzYrC
z6cTc8r-Kchq(o28)xrVlBobe~>x<^qa9@Iq(x0_=%Dt`NHlnRi*zUrn!4Esz>`R$$
zAQH1|CkLYzowBO@oUGHM;4VJxl~L_EC(w$h;-N$fe|Gw$(svE6Ec?FL_^~NyShDb9
z=|oy@PaLqjsgCOt^>X@IIi!-MP<NrJmfsZtS=7<#Dt>ZjRav<9%p~MsH%tMsCnlZF
z4QZ4z2kXRdVtL%<!3ZmRgMI)>hF9COonKxx#XmkWXJs92WKni>tdGq<-3qRIZr_&@
zU@u(b$#dH-l(xL+<WL!;P};uu>7rq(Ro}G=rt>|P)5s0RYKynR;F7p;pShiyR`N)<
zr^3{>c@tJczRP)&#ricfjLS=_8^6XeCbdp%lVDZz!_tBbCfYC7ym<{arK(vOR`{DZ
zud1))A!kC+OyA1hhkn$)2W>5w2HLp(RTOa){paI;%OkyO6<1ZI8Ht%M71i@!IsvR-
zF-hHi8e^9ZG?sItzLDd^%1z7FwTd+z91p73BRO9c?Pcsh+zK)y3-#Tu7+o~BL09$#
z=g}&)U;;TP2T@g(p80W9UwIjq=v2hwaEo!s)_q@?t6jP>SHwEm88viqDeFy7OxEqE
zYm2j61r+&;HPPBUueA#AYCra+l7`uc9u|5*eThC|vpHMig8J3y=`?)zi)}45%4&P^
z@$(_H^oZaB+u-zF)RmsNBiR+1`<;5Kq9B5gkEEYpWGErA%50p=<eJDj6Y`{1VOpEV
zm|&Xt6H-bXt|u2}Zn4naDvR1AGD2%Q{5$D&m`|BLYm)hqkrG)}Fu9gxm4z|U*ceaB
zh%2kuV)en6#7i9d{2BxnHeF{oElig6o-V3|ZB}S3xx$FHej`-XHu@UTX=`-e$$r{`
z-!lU+^$C=d_AwWJ22maeNV|2figw-E&GGz6)PT(E%fJIE(;+-|6h(jpcQf}ETph;p
zzis#>+|`&HEJb(VIHh7CiMWOy#e4>4V?=-?LmV19I+&ZZyI;;{)_EvpN^A6IF%2$J
zmI5dNZUF*05NP<*tH4uCv5h^Wz(oGkKg7uM7ZCpk5G|-NbKN?7p1HSthi3!OpKT5F
z2J#vK)cYS_DdC0CqPMb-qIX;JqypU8+Yq7-VKSF<`|~!^^fy0?z@~8G0qD7H7eL$r
zrP``X3{c;=s+$p7yDSd;2lCBu!7_+jU-~Q`0;H#Hy{bgnmOBZW{*&}HDT?tV-0?n4
z;;5WhpzhfAKo^bPo`GE**)hCI25n5xOHeegV)`siFeksQm;yYbb@cWii#11=7uey}
zC^FmQF6Q>!OU`cXP9SlqyKFGd#bA%xESt^do=Rc8-QyrxX8T&PHLg#)CAq*$$}`Zf
zEIBJ<yplSxv3dvuvN2F5*W9*ZCUP1Jl>|2<Wembg46?8=RLb_Wxuu2neN1N7XCen`
zW#c=}yYAR`M%X449v`b8%dBV%3^YDHQXAWoIas4)zRhhi%m^O!6ZuB~M2!W4RJK_T
znC0YrSW#MJZ4-n=IZnEal8lJXIONj~7BDh9e_VQpo^&-r8(Xb6C8vuc9IfVj{>dVn
zyU?&Z<rwlu5uon9aVw{&3@#OaXbq75*waoO+n#=(JjfV3gP3f2!$Etk(`fs+xZ>$u
z!7><Ein6n5=bE}|R`UrtjF+9xJDh?mJ_-*Gpy>07U%$yKGeWBE&g+Z9+n1K=<pNWx
zb)<r<!K_Houa`O_rCeBsn3mMJ*GB7YIBsW0UqI_ew;17yrzvfB3_azM&_E=2It20l
z$Hcb^8084h_h+yeMswwvfj>;sg9a{7?#kHMtJ>P>3c|5Cjri(Sfbo%7FmnOVxMp9J
zMKBba$H#~2rkGv%ojI8j2(V&U!g5!<kjBclaF;;ZT5nxuS~p(L@)G{EJOZqyKJw$7
z@S&QQWGjcH@%gL(rlWXrir|Pq-apA+lm$^bM5yK@t*vEw;+k&`FL0zl!>JYoQ}E_(
z`VqbY9BryE7B}T-+crOBc<}u~vXvy~b!1_riDgoSqS-*yMC!-GQ8vCPD)Q$NK)Dy=
z;ul?uZQEaq1)vqbM;d>#(0g3^aYgYYAk`~f%6<{}?t}C7LUOAy`271p<LKuQUXzN_
zvLp*k8ntz~ec6trYThV;NER3cS~0*5ZNQFow{L*E!1~uytvbx@GRt_jUwnC<qW5gl
zlGXHGHvz10ouD<r7_z%&W3NyOsH;x)EzTCSeSFPKOlDPEqKjh`q%4qb#Ur><=tO7;
zzxE2>X$q6)pGXcXt)pIACX^H<ttM51(vY5AcXPS(lB~Y`#lNk7K*zkdOnWR;s4;GQ
z{5Ea-xT4GniCLVVvWW-+pe_*Qd(85_f-ik-ORz@uBt1&}pf%v}<<uc|q;HP9e#LZY
z{aB<)BA|hL+(wU)$G7STpo`tK7caatzBJ|3n_?AU)i(ISx$O^X%5p{-p1gB<FX$2m
zH!uDPw2XlcuUewZ^^n|oXMS*LWgWOChX8XAG<~<1>*A<4BZ;2Rsm3d7p_(zRy&Lxf
zdOIho2P2x;figw}AEE{2o|xDXFgIA-US|6HA0nZ(vw@jdlcSvI>9x>pVvt0#%JkIz
z)!0RB&<-TaW4~wVc2#h`AVC~8X8I?4cMetooM3)d-*Ml6N_5U&J^%2ONm95fpm@5f
zMHW>`;B)G?ubnfQ2%qyZDr!EsD%UJ=c{Vs&!Pi5VAM$c}sdJUh|NOSstyQoPzb=xS
zi!EJu!-7!hr}(mjUgcfx^H1S+doGc-6!`v-b@U9Y@A!5jkH~;ZUdCs-l&A3(m~B8P
zMQ1?nJMRGb1Me?5?CE^$YDHZ7{>SAJ^lIFW+jwZmo-Q$f2)GF7-atMrRJb!H2gwKI
zcDEg7AeP!HynE{{hx&Q(OC`60ftFf(C+~mm1+*j|G+hV&e$!e$A|gWE>MLw|W`-~P
z-HVm36f)uG9wN@}waWI~F9rD8WmiG!1gk|vzRZDQzoHSr>b1exg{(2M;Pfo;WIA|X
z<DJziU}VGdIW%{@6*JD?NJ;kfoD62JpW{`NeslEeGI<$@?>BGrarpgo=r5h;iDb@%
z2hgh{0b@z*If0}AgRK&buWy2KC%bp?t7-aV+}ap}PbI$;U_fqZ_dBDzUc8c&*7XIL
z9?0NV?E-N`aZWupe$0~_C|<GUMNFmH2a>IGx+_Ln?teB1`?Rv1#x^{OsnnZ;VxGQ~
zfevoSI%;4LCwdoEj4=nVqej|#lO_}|?TWNouKzxJ{q}N3sDORYMBdzH^+JBI3G!am
zZ}RX{hs?t}_cukSY425fwqB{cYh_m-m6~#)s3J<#jR6kVa~}LbSsHXRVH;y)N5E&Z
z@;5aVjLGsj<Tb^4TlojkR?C$Izu#mBD`F9h#v-Mp&bjGzMcp6D`~GbVyXU^v@GTKW
z&fOE6D%OI9X1(LVx1+ji93ngoTChT$jJ4Z5PaP@q9coFf;>pM~0%-8ru&b~0a{A<y
z+E0pxugj6V3H6S-%GpscAX}L}FhpkNdKtkqPy0+UX+H8gsQtf{nYjUBZcWP;fvL||
zeQIW>f{#Hg`BA@J&b=9#oNTFVOS$E;T(vdUOvd=dd8+<%sj12VZ6ygn?%SQo?k!yg
zlr29^-3?4MlJcY8;^M&%Z%`%Gv<-$=cU9k5j{SXhy+bK}*wc69$+r9I>!yAW)z7wo
z0XQ;!0BGI8>Q(#O>))y7_Z|5<@RsP5l=9=_8mg`=^tiaBE`88KgpUC(&sUDlZ{>U;
zTQA@WumAA7u716G;;X4O9$Ms4OCv{ZzYq{o48`Z|xzd`C#ece0yi4Wik08>nulsEp
zm-kf7nYA2>+J6hRZ^be>-$L4T!Wzk4wST(4^_oQNY)ac*?mwZ1B0U`PcYVisNa2`2
zu-bj)2mDAb%L!X*h=I_oyr`WgPnsb2_~-l%R-F<^XXHYFT!5aKeDP|ts*&lQMwuYU
zAN_h+E;jCteEM#gHZTr<+v|JOo;xx;^Qb?)8c9oI%v&-_ktIX{lByEixzo+kZbV-H
zm<D^oKzes>NK=~&K3e~-xz>ueJMb)j(wu2d%hk7+iNpTDw7{lvb|8OvmTiSrUH3uz
z-fzg8s}@GrFMsXi+twhl{xrqquF{!hZ+^>VVm6;Jfnj2D%RPgcVz%XyQu+MXkrDZd
zu#;S{KS@mB9R~bHK&X#<pj5$Jvg`Q0)hSr#2jxhH;&azO<|mWda}R>f<T!LfW5$s8
z7bnD98TM$2buwX0woS@WP79#&2aDAT`UT$XXZ26&Vtw4bc;n1E=y>Kzt?xE)$}2rY
zMV>PE1l_V<TfV<yyp6Z^1Fzue#EFhFx?5Z`SN-y0V`cS8e!}V+`6pFd1ROTrX%c%m
znWnT_s`A7DC#XMU4T5kyIp-6&W_3tjEm&LK)9|$IeP7g+?9aaD(@6leDAGd#)PZfP
z=UOW(@gdqZA`vwEf#yFK6X_qQaGr*d{5Er4v4hF87B-VzQ&c#q*BorDp81DeO}5Ew
zYbM)>B=-HqCVFExI29}EXUSD#C9@G998X0uCKy_T>DRF<G8~|{GHa6mflv5WCk-W~
zHv@Bx%@IE&e`XD7_&6rfJ_6d9Yv$nUvu%D~FH3Y-r4sG;7!mZGH^gT1&Z&j{dB;JY
z!!DM3UcOiaNiFwEg~Ht($*tNj{(IL$O@>bxv>3q96~=w^m|0xcOyihzZCTTGuFFbh
z7AvZg_!_sB6?MBp5Ac(zTNc~n@T3LH|3w;mL-bM}K~sUn<Pp1zU1BP|(X*X6Rrw8z
z=hRNzO>q=;cWF*({o~@~UL&xt{g76Mdm))hV-^uQ1@r^2Dew)gIga&YfzflJ^Pznu
zv1SGpA(!bTQ*<PdFhD*91vb7;NY%+T`DyM}c<oShRJUH6^KJ$(x#fMLc&~}1eDV+$
zkC_ED*+^@v<KTm}W_K!YD>Oi@GJ6)0zB7f<c_q;fHI<6J<}faU=>qc-Q*9eHE4z`h
z*iw|5cF%H&lezY)J{t;5H-O>(!XKcB!SRL13-m0x0n(TI;h-(LEtAF)6}=t#=$3?h
z8C9ti+Rj}-6iQ<4K4*$}<XABjX`&e#`up{4qAy>k<4LPG!b!`%3+kC8;GNP};K1D0
zQbzsgM#cAVI{|PYAuQS%b<xJx-XkPc&wNLVU!28h)|)&_muZl3K{+eB0Ah2(y*hX$
z5Rm}?ov|6o$cW?P&`km#cc$ghdNLc&;gfD}#&_bfO+~!r&~0l*y(L4U1T8!{3Lm>T
zX%X`{_nqeZTq^DfAX-VfunIuPO26)>bBo1_n^zZzWdcHt7HM-b?c=Lt2{J|w-U4<Z
zXGXHCol4#yck1v&)Q+|zWS~na-*zBAT8|!=hm(AX4(#d4J8PmKaJ&Ft4Yx@s+*da#
zqdz;dD)fEq#`DvbWOxM4IE{L}lPyyZ;G5AWWo2CI$)r)5WN(d6iL_p3NVJSWz*Stu
zWtM8$o}G>h$R|vVRUw54=sS<UI0wTOF$*=pI32vTtr-6#L`AxNR<`qXK`z`{fpL{J
z$yEUFLSi;|gWmSyV?0q;2(`~AF?FKPz=aWfe-#=aHJ}gOz7nX<J8)#D`0R9i03;Ct
zrYGBajlJbNZ!`}BFSq&a-LYl6xa>SM4)pH+<Nwqf|0j!;OEVWH3^4ftQ>7F+`#=|s
zc8&*Qm2M-K{uNkN7)&NMF0R1R`HU6;bSGz4dntqAuOL0LmzhZKP<-|MsUQ}ZpBw=i
zR*rNz1p4hJ0Dx={?+@n&v=90+ijlK3Gws7i-zw+KMvx(EWXrTr|7{oq+guq<n$wq=
z%cz>IBL`b;g1xPoJ`8;ozPgdHU|{6p4?N|mTSHWM{{vX3=R08I?uux|h0qc@{R+X0
zHSu1y?u+rkoyPbfiWd?Oj|mg(^`s3fT~m%6I)fTx=f0><mJ6}bUj)^rg3(>ey336Y
zzG=&9kPUx2$#FsrHStuSus$gLy%Y^@<Gno{x{<aG2Z6~hF9$2YJ-oIjE<9i<y|ir&
zehy!y46Ks`@J!2_4I`Ic!sr6nF>#6YuqdlV<%ecb3_#up9Z0)Q04YB}@j;H11A46v
z=WnL3SJF%OTkvE-Bd0Dl$MQTRdAbaC@98)9!2tbWXoTLqpX`o_^_R26Ep?h=n@Ol!
z4ysZA79Z1RTgUp|c^hNC;F3ltN3My7<#-&k_(BZ%qFTPz>yaJ=8p4uA)-r#sbI&()
z1Aa7VBsSdTE>H&Salx7l_u2xlJ6i4;+K9#<`J;Sg{hcy52bz{~@t2f67?G}IxkrX)
zcxb5+8yGg`8b3?e>S(Ui%7C^P*Kx||64GjaiUJ-#)vtwa+uv7Tsdbu~4nA<5l>@CQ
z;wUfe9v)$>p94%^HDg-#ejpE_CQ-ZTfQrS&`#2CcN8Hn)$Sdv1zho~TeI?(xV7#g>
zNUdr7IePa~*i20yxMkqMaK7-{+U#{zEPi<2cZ60ua!D<gwK!bifN;#H1$H3E?Dlh$
z+h$`P0xWBA^1DdsE5d>wswxK_xbr+p>dZ8$R9~?~P403(w-(kPI{b4pb6L$5NsjFl
zP|t^3r3X!EbyY_~+p8`L0EegdEf~iGdRzMfr3`=OTo?nDt#A9W{qvpSolq2B^X9L{
zO*h`wcx}f#7+V979k(9>PT&5W1NIyW$MO#cr3-9tZ728qKRk~+hkHEP#$)>)e;J?c
zGk=S@04T{`t$d2uHt7bCGW;I%pw~Va62dOZ?g4??0lU;52|$L*-msU{o;qv}MTEaa
zIe9#h1rDeO=z$3nm~YB#(<O87?nmL_Jj}hHoWv040#8NZ%`?<j-f<nJB#OxF)7kSt
z>|pJlBR@dpL1KFLX$!b*KkOkyGFponH#60h?uZ$c3*9}&@qp2!%RqWCwg;yAnt_TB
z6{8-_Tn&eUh{BW`zw-bBtN(Zd>?GKz{Bl3&D5xNUlY!L119taDx0(pq7vH+T+5-g<
zgj4&8r+_7{f5_#m4R^o7@u25f>qq2&k*IGw{J;Gt9nSglZfRVdP0)>%rmk)OtqAxH
Lgl5^bTaW$+T!Mh1

literal 0
HcmV?d00001

diff --git a/images/dark/clear-all.svg b/images/dark/clear-all.svg
new file mode 100644
index 0000000..316bbe2
--- /dev/null
+++ b/images/dark/clear-all.svg
@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" aria-hidden="true" focusable="false" width="1em" height="1em" style="-ms-transform: rotate(360deg); -webkit-transform: rotate(360deg); transform: rotate(360deg);" preserveAspectRatio="xMidYMid meet" viewBox="0 0 16 16"><g fill="white"><path d="M10 12.6l.7.7l1.6-1.6l1.6 1.6l.8-.7L13 11l1.7-1.6l-.8-.8l-1.6 1.7l-1.6-1.7l-.7.8l1.6 1.6l-1.6 1.6zM1 4h14V3H1v1zm0 3h14V6H1v1zm8 2.5V9H1v1h8v-.5zM9 13v-1H1v1h8z"/></g></svg>
\ No newline at end of file
diff --git a/images/light/clear-all.svg b/images/light/clear-all.svg
new file mode 100644
index 0000000..3bb24db
--- /dev/null
+++ b/images/light/clear-all.svg
@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" aria-hidden="true" focusable="false" width="1em" height="1em" style="-ms-transform: rotate(360deg); -webkit-transform: rotate(360deg); transform: rotate(360deg);" preserveAspectRatio="xMidYMid meet" viewBox="0 0 16 16"><g fill="black"><path d="M10 12.6l.7.7l1.6-1.6l1.6 1.6l.8-.7L13 11l1.7-1.6l-.8-.8l-1.6 1.7l-1.6-1.7l-.7.8l1.6 1.6l-1.6 1.6zM1 4h14V3H1v1zm0 3h14V6H1v1zm8 2.5V9H1v1h8v-.5zM9 13v-1H1v1h8z"/></g></svg>
\ No newline at end of file
diff --git a/package.json b/package.json
index ced50e7..ae2aa9d 100644
--- a/package.json
+++ b/package.json
@@ -37,6 +37,7 @@
         "onCommand:vscode-kafka.consumer.consume",
         "onCommand:vscode-kafka.consumer.list",
         "onCommand:vscode-kafka.consumer.toggle",
+        "onCommand:vscode-kafka.consumer.clear",
         "onCommand:vscode-kafka.explorer.copylabel",
         "onCommand:vscode-kafka.explorer.deleteselected",
         "onView:kafkaExplorer",
@@ -270,6 +271,15 @@
                     "light": "images/light/toggle.svg",
                     "dark": "images/dark/toggle.svg"
                 }
+            },
+            {
+                "command": "vscode-kafka.consumer.clear",
+                "title": "Clear Consumer View",
+                "category": "Kafka",
+                "icon": {
+                    "light": "images/light/clear-all.svg",
+                    "dark": "images/dark/clear-all.svg"
+                }
             }
         ],
         "menus": {
@@ -337,6 +347,11 @@
                     "command": "vscode-kafka.consumer.toggle",
                     "group": "navigation",
                     "when": "resourceScheme == kafka"
+                },
+                {
+                    "command": "vscode-kafka.consumer.clear",
+                    "group": "navigation",
+                    "when": "resourceScheme == kafka"
                 }
             ]
         },
diff --git a/src/commands/consumers.ts b/src/commands/consumers.ts
index 9204721..7da8b81 100644
--- a/src/commands/consumers.ts
+++ b/src/commands/consumers.ts
@@ -5,6 +5,7 @@ import { pickTopic } from "./common";
 import { ClusterSettings } from "../settings";
 import { CommonMessages } from "../constants";
 import { KafkaExplorer } from "../explorer";
+import { ConsumerVirtualTextDocumentProvider } from "../providers";
 
 export interface StartConsumerCommand {
     clusterId: string;
@@ -17,7 +18,7 @@ export class StartConsumerCommandHandler {
         private clusterSettings: ClusterSettings,
         private consumerCollection: ConsumerCollection,
         private explorer: KafkaExplorer
-        ) {
+    ) {
     }
 
     async execute(startConsumerCommand?: StartConsumerCommand): Promise<void> {
@@ -55,6 +56,9 @@ export class StartConsumerCommandHandler {
 }
 
 export class ToggleConsumerCommandHandler {
+
+    public static COMMAND_ID = 'vscode-kafka.consumer.toggle';
+
     constructor(private consumerCollection: ConsumerCollection) {
     }
 
@@ -75,6 +79,25 @@ export class ToggleConsumerCommandHandler {
         }
     }
 }
+export class ClearConsumerViewCommandHandler {
+
+    public static COMMAND_ID = 'vscode-kafka.consumer.clear';
+
+    constructor(private provider: ConsumerVirtualTextDocumentProvider) {
+
+    }
+    async execute(): Promise<void> {
+        if (!vscode.window.activeTextEditor) {
+            return;
+        }
+
+        const { document } = vscode.window.activeTextEditor;
+        if (document.uri.scheme !== "kafka") {
+            return;
+        }
+        this.provider.clear(document);
+    }
+}
 
 enum ConsumerOption {
     Open,
@@ -144,7 +167,7 @@ async function openDocument(uri: vscode.Uri): Promise<void> {
 
     // If there's no document we open it
     if (!document) {
-       document = await vscode.workspace.openTextDocument(uri);
+        document = await vscode.workspace.openTextDocument(uri);
     }
 
     // Check if there's an active editor, to later decide in which column the consumer
@@ -163,12 +186,12 @@ async function openDocument(uri: vscode.Uri): Promise<void> {
     // Instead, a new TextEditor instance is added to the active panel. This is the
     // default vscode behavior
     await vscode.window.showTextDocument(
-            document,
-            {
-                preview: false,
-                preserveFocus: true,
-                viewColumn: hasActiveEditor?vscode.ViewColumn.Beside:vscode.ViewColumn.Active,
-            }
-        );
+        document,
+        {
+            preview: false,
+            preserveFocus: true,
+            viewColumn: hasActiveEditor ? vscode.ViewColumn.Beside : vscode.ViewColumn.Active,
+        }
+    );
     await vscode.languages.setTextDocumentLanguage(document, "kafka-consumer");
 }
diff --git a/src/extension.ts b/src/extension.ts
index e77511e..f18026b 100644
--- a/src/extension.ts
+++ b/src/extension.ts
@@ -15,6 +15,7 @@ import {
     DeleteClusterCommandHandler,
     SelectClusterCommandHandler,
     handleErrors,
+    ClearConsumerViewCommandHandler,
 } from "./commands";
 import { Context } from "./context";
 import { BrokerItem, KafkaExplorer, TopicItem } from "./explorer";
@@ -50,6 +51,7 @@ export function activate(context: vscode.ExtensionContext): void {
     context.subscriptions.push(explorer);
     context.subscriptions.push(new ConsumerStatusBarItem(consumerCollection));
     context.subscriptions.push(new SelectedClusterStatusBarItem(clusterSettings));
+    const consumerVirtualTextDocumentProvider = new ConsumerVirtualTextDocumentProvider(consumerCollection)
 
     // Commands
     const createTopicCommandHandler = new CreateTopicCommandHandler(clientAccessor, clusterSettings, explorer);
@@ -58,6 +60,7 @@ export function activate(context: vscode.ExtensionContext): void {
     const startConsumerCommandHandler = new StartConsumerCommandHandler(clientAccessor, clusterSettings, consumerCollection, explorer);
     const listConsumersCommandHandler = new ListConsumersCommandHandler(consumerCollection);
     const toggleConsumerCommandHandler = new ToggleConsumerCommandHandler(consumerCollection);
+    const clearConsumerViewCommandHandler = new ClearConsumerViewCommandHandler(consumerVirtualTextDocumentProvider);
     const addClusterCommandHandler = new AddClusterCommandHandler(clusterSettings, explorer);
     const deleteClusterCommandHandler = new DeleteClusterCommandHandler(clusterSettings, clientAccessor, explorer);
     const selectClusterCommandHandler = new SelectClusterCommandHandler(clusterSettings);
@@ -108,8 +111,12 @@ export function activate(context: vscode.ExtensionContext): void {
         "vscode-kafka.consumer.list",
         handleErrors(() => listConsumersCommandHandler.execute())));
     context.subscriptions.push(vscode.commands.registerCommand(
-        "vscode-kafka.consumer.toggle",
+        ToggleConsumerCommandHandler.COMMAND_ID,
         handleErrors(() => toggleConsumerCommandHandler.execute())));
+    context.subscriptions.push(vscode.commands.registerCommand(
+            ClearConsumerViewCommandHandler.COMMAND_ID,
+            handleErrors(() => clearConsumerViewCommandHandler.execute())));
+
     registerVSCodeKafkaDocumentationCommands(context);
 
     // .kafka file related
@@ -123,8 +130,7 @@ export function activate(context: vscode.ExtensionContext): void {
         vscode.languages.registerCodeLensProvider(documentSelector, new ProducerCodeLensProvider()));
 
     context.subscriptions.push(vscode.workspace.registerTextDocumentContentProvider(
-        ConsumerVirtualTextDocumentProvider.SCHEME,
-        new ConsumerVirtualTextDocumentProvider(consumerCollection)));
+        ConsumerVirtualTextDocumentProvider.SCHEME, consumerVirtualTextDocumentProvider));
 }
 
 export function deactivate(): void {
diff --git a/src/providers/consumerVirtualTextDocumentProvider.ts b/src/providers/consumerVirtualTextDocumentProvider.ts
index 9f8935b..f041fa4 100644
--- a/src/providers/consumerVirtualTextDocumentProvider.ts
+++ b/src/providers/consumerVirtualTextDocumentProvider.ts
@@ -4,6 +4,7 @@ import { ConsumedRecord, ConsumerChangedStatusEvent, ConsumerCollection, Consume
 import { CommonMessages } from "../constants";
 
 export class ConsumerVirtualTextDocumentProvider implements vscode.TextDocumentContentProvider, vscode.Disposable {
+
     public static SCHEME = "kafka";
     private buffer: { [id: string]: string } = {};
     private disposables: vscode.Disposable[] = [];
@@ -32,10 +33,9 @@ export class ConsumerVirtualTextDocumentProvider implements vscode.TextDocumentC
     }
 
     public provideTextDocumentContent(uri: vscode.Uri): string {
-        if (!this.buffer.hasOwnProperty(uri.toString())) {
+        if (!this.isActive(uri)) {
             return "";
         }
-
         return this.buffer[uri.toString()];
     }
 
@@ -60,27 +60,20 @@ export class ConsumerVirtualTextDocumentProvider implements vscode.TextDocumentC
     }
 
     private onDidChangeStatus(uri: vscode.Uri, status: string): void {
-        let uriBuffer = this.buffer[uri.toString()];
+        if (!this.isActive(uri)) {
+            return;
+        }
         const line = `Consumer: ${status}\n\n`;
-        uriBuffer = uriBuffer + line;
-
-        this.buffer[uri.toString()] = uriBuffer;
-        this.onDidChangeEmitter.fire(uri);
+        this.updateBuffer(uri, line);
     }
 
     private onDidReceiveRecord(uri: vscode.Uri, message: ConsumedRecord): void {
-        let uriBuffer = this.buffer[uri.toString()];
-
-        if (!uriBuffer) {
+        if (!this.isActive(uri)) {
             return;
         }
-
         let line = `Key: ${message.key}\nPartition: ${message.partition}\nOffset: ${message.offset}\n`;
         line = line + `Value:\n${message.value}\n\n`;
-        uriBuffer = uriBuffer + line;
-
-        this.buffer[uri.toString()] = uriBuffer;
-        this.onDidChangeEmitter.fire(uri);
+        this.updateBuffer(uri, line);
     }
 
     private onDidCloseConsumer(uri: vscode.Uri): void {
@@ -93,25 +86,46 @@ export class ConsumerVirtualTextDocumentProvider implements vscode.TextDocumentC
 
     private onDidCloseTextDocument(document: vscode.TextDocument): void {
         // When language is plaintext we assume the event was triggered as a result of switching language mode
-        if (document.uri.scheme !== "kafka" || document.languageId === "plaintext") {
+        const uri = document.uri;
+        if (uri.scheme !== "kafka" || document.languageId === "plaintext") {
             return;
         }
 
-        const buffer = this.buffer[document.uri.toString()];
-
-        if (!buffer) {
+        if (!this.isActive(uri)) {
             return;
         }
 
-        if (this.consumerCollection.has(document.uri)) {
-            this.consumerCollection.close(document.uri);
+        if (this.consumerCollection.has(uri)) {
+            this.consumerCollection.close(uri);
         }
 
-        delete this.buffer[document.uri.toString()];
+        delete this.buffer[uri.toString()];
+    }
+
+    public clear(document: vscode.TextDocument): void {
+        const uri = document.uri;
+        if (!this.isActive(uri)) {
+            return;
+        }
+        this.updateBuffer(uri, '', true);
     }
 
     public dispose(): void {
         this.consumerCollection.dispose();
-        this.disposables.forEach(d=>d.dispose());
+        this.disposables.forEach(d => d.dispose());
+    }
+
+    private isActive(uri: vscode.Uri): boolean {
+        return this.buffer.hasOwnProperty(uri.toString());
+    }
+
+    private updateBuffer(uri: vscode.Uri, content: string, replace = false) {
+        if (replace) {
+            this.buffer[uri.toString()] = content;
+        } else {
+            const uriBuffer = this.buffer[uri.toString()];
+            this.buffer[uri.toString()] = uriBuffer + content;
+        }
+        this.onDidChangeEmitter.fire(uri);
     }
 }