METHOD_0 ( ) { org . apache . kafka . IDENT_0 . consumer . IDENT_1 < byte [ ] , byte [ ] > record = new org . apache . kafka . IDENT_0 . consumer . METHOD_1 ( STRING_0 , 0 , INT_0 , STRING_1 . getBytes ( ) , "value" . getBytes ( ) ) ; org . apache . hadoop . hive . kafka . IDENT_2 IDENT_3 = new org . apache . hadoop . hive . kafka . METHOD_2 ( record . METHOD_3 ( ) , record . offset ( ) , record . METHOD_4 ( ) , record . value ( ) , null ) ; java . io . ByteArrayOutputStream IDENT_4 = new java . io . ByteArrayOutputStream ( ) ; java . io . IDENT_5 IDENT_6 = new java . io . METHOD_5 ( IDENT_4 ) ; IDENT_3 . write ( IDENT_6 ) ; IDENT_6 . METHOD_6 ( ) ; java . io . ByteArrayInputStream input = new java . io . ByteArrayInputStream ( IDENT_4 . toByteArray ( ) ) ; java . io . IDENT_7 IDENT_8 = new java . io . METHOD_7 ( input ) ; org . apache . hadoop . hive . kafka . METHOD_2 IDENT_9 = new org . apache . hadoop . hive . kafka . METHOD_2 ( ) ; IDENT_9 . METHOD_8 ( IDENT_8 ) ; "<AssertPlaceHolder>" ; } METHOD_8 ( java . io . IDENT_10 ) { IDENT_11 = org . apache . hadoop . io . IDENT_12 . METHOD_9 ( in , org . apache . hadoop . hive . IDENT_13 . IDENT_14 . IDENT_15 . IDENT_16 . class ) ; IDENT_17 = org . apache . hadoop . io . IDENT_12 . METHOD_10 ( in ) ; try { IDENT_18 = java . lang . Class . METHOD_11 ( org . apache . hadoop . io . IDENT_12 . METHOD_10 ( in ) ) ; IDENT_19 = java . lang . Class . METHOD_11 ( org . apache . hadoop . io . IDENT_12 . METHOD_10 ( in ) ) ; IDENT_20 = java . lang . Class . METHOD_11 ( org . apache . hadoop . io . IDENT_12 . METHOD_10 ( in ) ) ; } catch ( java . lang . IDENT_21 e ) { throw new java . io . IOException ( e ) ; } }
org . junit . Assert . assertEquals ( IDENT_3 , IDENT_9 )