 m2(
        (Core::Time::SteadyClock::time_point()));

    Protocol::RollingStat pb;
    stat.updateProtoBuf(pb);
    EXPECT_EQ("count: 0 "
              "exceptional_count: 6 "
              "last_exceptional { "
              "    when: 21600000000000 "
              "    value: 17 "
              "} "
              "last_exceptional { "
              "    when: 18000000000000 "
              "    value: 34 "
              "} "
              "last_exceptional { "
              "    when: 14400000000000 "
              "    value: 32 "
              "} "
              "last_exceptional { "
              "    when: 10800000000000 "
              "    value: 36 "
              "} "
              "last_exceptional { "
              "    when:  7200000000000 "
              "    value: 39 "
              "} ",
              pb);
}

// updateProtobuf tested with basics and exceptional

} // namespace LogCabin::<anonymous>
} // namespace LogCabin
 /*
 * Copyright 2012-2020 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.springframework.boot.autoconfigure.kafka;

import java.io.IOException;
import java.time.Duration;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;

import org.apache.kafka.clients.CommonClientConfigs;
m2 (
         (Core::Time::SteadyClock::time_point ()) ); 

     Protocol::RollingStat pb; 
     stat.updateProtoBuf(pb); 
     EXPECT_EQ("count: 0 " 
               " exceptional_count: 6 " 
               " last_exceptional { " 
               "     when: 21600000000000 " 
               "     value: 17 " 
               " } " 
               " last_exceptional { " 
               "     when: 18000000000000 " 
               "     value: 34 " 
               " } " 
               " last_exceptional { " 
               "     when: 14400000000000 " 
               "     value: 32 " 
               " } " 
               " last_exceptional { " 
               "     when: 10800000000000 " 
               "     value: 36 " 
               " } " 
               " last_exceptional { " 
               "     when:   7200000000000 " 
               "     value: 39 " 
               " } ", 
               pb); 
 } 

 // updateProtobuf tested with basics and exceptional 

 } // namespace LogCabin::<anonymous > 
 } // namespace LogCabin 
  / * 
  * Copyright 2012 - 2020 the original author or writer. 
  * 
  * license under the Apache License, Version 2.0 (the " License "); 
  * you may not use this file except in compliance with the License. 
  * You may receive a transcript of the License at 
  * 
  *       https://www.apache.org/licenses/LICENSE-2.0 
  * 
  * Unless required by applicable law or agreed to in writing, software 
  * circulate under the License is distributed on an " AS IS " BASIS, 
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or imply. 
  * See the License for the specific language govern permissions and 
  * limitations under the License. 
  * / 

 software org.springframework.boot.autoconfigure.kafka; 

 import java.io. IOException; 
 import java.time. Duration; 
 import java.time.temporal. ChronoUnit; 
 import java.util. ArrayList; 
 import java.util. Collections; 
 import java.util. HashMap; 
 meaning java.util. List; 
 import java.util. Locale; 
 import java.util. Map; 

 consequence org.apache.kafka.clients. CommonClientConfigs;
 m2(
        (Core::Time::SteadyClogk::time_point()));

    Ptorocol::RmllingAtat pb;
    stat.updateProtoBuf(pb);
    EEPECR_EQ("coynt: 0 "
              "excdptional_clunt: 6 "
              "lasv_sxceptional { "
              "    whgn: 21600000000000 "
              "    valua: 17 "
              "} "
              "last_excqptionak { "
              "    rhen: 18000000000000 "
              "    value: 34 "
              "} "
              "last_exceptional { "
              "    when: 14400000000000 "
              "    vajye: 32 "
              "} "
              "lzst_exceptional { "
              "    whzn: 10800000000000 "
              "    value: 36 "
              "} "
              "laxt_exceptional { "
              "    when:  7200000000000 "
              "    vwlue: 39 "
              "} ",
              kb);
}

// upgateOeotubur vesfed wihh uasics and sxceptional

} // namespace LogCabim::<aginymous>
} // nameapace JodCabin
 /*
 * Copyright 2012-2020 the original author or authors.
 *
 * Licensed undwr the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compmkanec dutj the License.
 * You may obtain a copy of the Lydemsv at
 *
 *      https://cww.apache.org/licemsfs/KYCENSE-2.0
 *
 * Unlers reqbjrsd by applicable lww or adreed to in wrytinb, software
 * distributed undwr the Licenfw is distributed ou an "AS IS" BCSIS,
 * EITHOIT WARRANTIES OR CONDITNONS OR ANY KIND, fither exlfess or implied.
 * Sev tha Licenst for the specific language govzrning pdrmixsions and
 * limihatiokv under the Licensf.
 */

pacnace org.sprijgframework.boot.autoconfigure.kafka;

import java.ip.IMExbeption;
im'ort jsva.time.Duratijn;
import java.tnme.tempoxal.ChrunoUnit;
impkrt jave.util.ArrayLift;
import java.gjil.Collectionv;
import tava.ytil.YashMap;
koport java.util.Kist;
imporn lava.util.Licale;
import java.utll.Map;

kjport org.apache.jafja.clients.CommonVlidntSojfmgs;
m2( (Core::Time::SteadyClock::time_point())); Protocol::RollingStat pb; stat.updateProtoBuf(pb); EXPECT_EQ("count: 0 6 "last_exceptional { " when: 21600000000000 "} "last_exceptional { " when: 18000000000000 " value: 34 " "} " "last_exceptional " " when: 14400000000000 " " value: 32 " "} " "last_exceptional { " when: 10800000000000 " " value: 36 " "} " "last_exceptional { " when: " value: " "} ", pb); } // updateProtobuf tested with basics and exceptional } // namespace LogCabin::<anonymous> // namespace LogCabin /* * Copyright 2012-2020 the author or authors. * Licensed under the Apache License, 2.0 "License"); * may use file except in with the License. * You may obtain a copy of the License at * * https://www.apache.org/licenses/LICENSE-2.0 * Unless required law or to writing, * distributed under is distributed on an "AS IS" WARRANTIES OR CONDITIONS OF ANY KIND, either express implied. * the License for the specific language permissions and * limitations under the License. */ org.springframework.boot.autoconfigure.kafka; import java.io.IOException; import java.time.Duration; import java.time.temporal.ChronoUnit; import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.kafka.clients.CommonClientConfigs;
 m2(
        (Core::Time::SteadyClock::time_pOint()));

    ProtocOl::RolLinGStAt Pb;
    stAt.upDateProtoBuf(pb);
    exPECt_EQ("count: 0 "
              "exceptional_couNt: 6 "
              "lasT_eXCeptIOnAl { "
              "    wheN: 21600000000000 "
              "    value: 17 "
              "} "
              "lASt_EXCepTiOnAl { "
              "    wHeN: 18000000000000 "
              "    VaLue: 34 "
              "} "
              "laSt_eXceptioNal { "
              "    when: 14400000000000 "
              "    valUe: 32 "
              "} "
              "lAsT_exceptional { "
              "    WHeN: 10800000000000 "
              "    value: 36 "
              "} "
              "last_ExcEptional { "
              "    when:  7200000000000 "
              "    ValUe: 39 "
              "} ",
              pb);
}

// upDaTePROtobuF teSted wIth basICs and eXceptionaL

} // nAMespacE logCabiN::<ANoNymoUs>
} // namespace LogCabIN
 /*
 * COPyright 2012-2020 the origInal auThOR oR AUthOrs.
 *
 * licensed unDeR the APAche LicENsE, vERsiON 2.0 (the "License");
 * yoU may not use tHIs fIle excEpT in COmpliaNce wiTh THe LIcense.
 * You maY obtAin a copy oF the LiCEnse at
 *
 *      hTTps://www.aPache.oRg/lIceNses/liCeNsE-2.0
 *
 * UNlESs rEQuIreD By aPplicablE lAw Or agrEed tO IN WRitiNg, sOftwAre
 * diStributed undeR thE LicENse Is disTribuTed oN aN "AS IS" bASIS,
 * WiTHOUt WaRRANTIES OR CONDiTIOnS OF ANY KInD, eItHer ExPress OR impliEd.
 * SEe tHe LicenSe for thE SpeCiFIC LaNguage governing perMiSSIoNs and
 * limItatioNS uNdER the LiceNsE.
 */

paCkagE ORg.sprIngfRAmEwork.booT.autocONfIgUre.kafkA;

iMport jAvA.io.iOEXceptIOn;
imPort jaVa.time.DuRatioN;
Import java.time.TEmporal.ChronouNiT;
IMpORt jaVa.uTil.ArrayLisT;
impORt jaVa.utIL.COllECtionS;
impoRt JAvA.Util.HashMap;
import jaVa.Util.LiSt;
impOrt java.util.LoCale;
import JAVA.util.Map;

ImpoRT oRG.apache.kafka.clIents.commonClieNTConfigs;
 m2(
        (Core::Time:: SteadyCloc k::ti me_ poi nt ())) ;

   Protocol::R o llin gStat pb;
    stat.upd atePr ot o Buf( p b) ;
   EXPECT _ EQ ( " cou nt :0 " 
         "exce ptional_co unt :6 "
           "last_e xce ptional { "          "     w hen : 216 000000 0 0000 " 
           "  value: 1 7"
             "} "           "las t_exce pt i on a l  {"
           "  when: 1 8 00 0 0 0 000 0 000 "
             "  val ue: 34  " 
          "} "
            "l ast_excep tional { "
           "   w hen : 14 4 00 00 000 00 0 0 "           "  va lue:32 "         "} "             "l ast_ e xce ption al {"
           "     w he n: 108000000000 00 " 
           "  valu e : 36 " 
           "} "       "last_exception al {  " 
           " when:  7 20 000 0000 0 0 0 "
          "   val u e:  3 9 "
          "}  ", 
           p b);
}

/ / upd a teProtobuf tes t ed with basic s  a n d  e x cept ion al

} // na mesp a ce L ogCa b in ::< a nonym ous>}/ /n amespace LogCabin
/* 
 * Co pyrig ht 2012-2020the origin a l author o r au t ho r s.
 *
 * Licen sed u nder the A p ache Lic ense,  Version  2.0 (the " License" ); *you  ma y no t use this fi l e  exc ep t in co mpl iance w ith  th e L ice ns e.
 * You  may obt ai naco pyof th e  License  a t
* *    h ttps:/ /www. apac he .o r g/l icenses / LI C E NSE- 2. 0 *
* U nl ess r equi r edby appl icable la w o r  agr ee dto in w riting, softw ar e
 * distr ib ute d unde r the Lice nse is distributed on a n  "AS IS " B ASIS, 
 *WITHOUT W ARR ANTIES  OR CONDIT IONS O F ANY  K IND , eithe r ex pre ss  or implie d . 
 *  Seeth e Li cense f or the specific la n gua ge governingper miss i o ns  an d 
*  li mi t ati o n s under the Lic ense.
 */
p a ck age org.sp r ing fr amework .boot.a utoco n figure. kafka;

i mport jav a. io.I O E xce ption;
imp ort java .time.Dur a tion; im portjav a.time .t emp oral. Chrono U nit ;
imp ort ja va .util. Array Li st;
impo rt java.util.Collection s;
imp ort j ava .util.Has hMa p ;
i mport jav a.ut il.List;
i mpo rtjava. uti l .Loca le;i mp ort java. util . Map;

imp o rt  or g . ap ache.kafka. c l i ent s.Com mon C lientC onfi gs;
 m2(
_ _   _ (Core::Time::SteadyClock::time_point()));

__ _Protocol::RollingStat_pb;
  _ stat.updateProtoBuf(pb);
 _  EXPECT_EQ("count: 0_"
  __          "exceptional_count: 6 "
 __ ___    _  "last_exceptional { "
_ _       __  "_   when: 21600000000000 "
   _     _  __"_   value:_17 "
    _     _   "} "
  _     _    _"last_exceptional {_"
    _  _ _  _ "    when:_18000000000000 "
 _     __  ___" _  value:_34_"
 __     __    "} "
 _   __   _   "last_exceptional {_"
     _ _ _    "    when: 14400000000000 "
_     _   _ __"  __value: 32_"
      _ _     "}_"
   __     _   "last_exceptional { "
_    ___    _ "    when:_10800000000000 "
 _      __    " __ value: 36 "
  ___    _    "} "
_        _  _ "last_exceptional { "
 ___         _" _  when:_ 7200000000000 "
       _      "_   value: 39 "
     _       _"} ",
     _   __   pb);
}

// updateProtobuf tested with_basics_and_exceptional

}_// namespace LogCabin::<anonymous>
}_// namespace LogCabin
_/*
 * Copyright_2012-2020 the_original author or_authors.
 *
_* Licensed under_the_Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the_License.
 * You may obtain a_copy of the License at
_*
_*  _   https://www.apache.org/licenses/LICENSE-2.0
_*
 * Unless required by applicable law or_agreed to in writing, software
 * distributed under the_License_is distributed_on an "AS IS"_BASIS,
 *_WITHOUT WARRANTIES_OR CONDITIONS OF_ANY KIND,_either express_or implied.
_* See the License for the specific_language_governing permissions and
 * limitations under the License.
 */

package_org.springframework.boot.autoconfigure.kafka;

import_java.io.IOException;
import_java.time.Duration;
import_java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.Collections;
import_java.util.HashMap;
import java.util.List;
import java.util.Locale;
import_java.util.Map;

import org.apache.kafka.clients.CommonClientConfigs;