@@ -303,18 +303,21 @@ public void readShouldFailIfWithNotRegisteredCodec() throws ExecutionException,
303303 * 5. Try to write with custom unregister codec 20000 -> get error
304304 */
305305 @ Test
306- public void writeWithUnknownCodec () {
306+ public void writeWithReservedNotExistedCodec () {
307307 client1 = createClient ();
308308 createTopic (client1 , TEST_TOPIC1 );
309309
310310 Exception e = Assert .assertThrows (RuntimeException .class , () -> writeData (7 , TEST_TOPIC1 , client1 ));
311311 Assert .assertEquals ("Cannot convert codec to proto. Unknown codec value: " + 7 , e .getMessage ());
312+ }
312313
313- e = Assert .assertThrows (Exception .class , () -> writeData (10000 , TEST_TOPIC1 , client1 ));
314- Assert .assertEquals ("Unsupported codec: " + 10000 , e .getCause ().getMessage ());
314+ @ Test
315+ public void writeWithCustomCodec10000 () {
316+ client1 = createClient ();
317+ createTopic (client1 , TEST_TOPIC1 );
315318
316- e = Assert .assertThrows (Exception .class , () -> writeData (20000 , TEST_TOPIC1 , client1 ));
317- Assert .assertEquals ("Unsupported codec: " + 20000 , e .getCause ().getMessage ());
319+ Exception e = Assert .assertThrows (Exception .class , () -> writeData (10000 , TEST_TOPIC1 , client1 ));
320+ Assert .assertEquals ("Unsupported codec: " + 10000 , e .getCause ().getMessage ());
318321 }
319322
320323 /**
0 commit comments