package Ġno . nav . sy fo . be handler . kafka Ċ Ċ import Ġio . micro meter . core . instrument . Counter Ċ import Ġno . nav . sy fo . metric . METR ICS _ NS Ċ import Ġno . nav . sy fo . metric . METR ICS _ REGISTRY Ċ Ċ const Ġval ĠK AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ BASE Ġ= Ġ"${ METR ICS _ NS }_ kafka _ consumer _ n lr " Ċ const Ġval ĠK AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ READ Ġ= Ġ"${ K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ BASE }_ read " Ċ const Ġval ĠK AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ DUPLIC ATE Ġ= Ġ"${ K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ BASE }_ duplicate " Ċ const Ġval ĠK AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ TO MB ST ONE Ġ= Ġ"${ K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ BASE }_ tom b stone " Ċ Ċ val ĠCOUNT _ K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ READ : ĠCounter Ġ= ĠCounter . builder ( K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ READ ) ĊĠĠĠ Ġ. description (" Counts Ġthe Ġnumber Ġof Ġreads Ġfrom Ġtopic Ġ- ĠDialog meld ing Best illing ") ĊĠĠĠ Ġ. register ( METR ICS _ REGISTRY ) Ċ val ĠCOUNT _ K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ DUPLIC ATE : ĠCounter Ġ= ĠCounter . builder ( K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ DUPLIC ATE ) ĊĠĠĠ Ġ. description (" Counts Ġthe Ġnumber Ġof Ġduplicates Ġreceived Ġfrom Ġtopic Ġ- ĠDialog meld ing Best illing ") ĊĠĠĠ Ġ. register ( METR ICS _ REGISTRY ) Ċ val ĠCOUNT _ K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ TO MB ST ONE : ĠCounter Ġ= ĠCounter . builder ( K AF KA _ CON SUM ER _ DIALOG ME LD ING _ BEST ILL ING _ TO MB ST ONE ) ĊĠĠĠ Ġ. description (" Counts Ġthe Ġnumber Ġof Ġto mb stones Ġreceived Ġfrom Ġtopic Ġ- ĠDialog meld ing Best illing ") ĊĠĠĠ Ġ. register ( METR ICS _ REGISTRY ) Ċ