@Test public void constructWithReflection() throws Exception { VerifiableProperties props = new VerifiableProperties(); Constructor<KafkaJsonDecoder> constructor = KafkaJsonDecoder.class.getConstructor(VerifiableProperties.class); KafkaJsonDecoder<?> decoder = constructor.newInstance(props); assertEquals(Object.class, decoder.getType()); assertEquals("hello", decoder.fromBytes("\"hello\"".getBytes())); }
@Override public T fromBytes(byte[] bytes) { return super.deserialize(null, bytes); }
KafkaJsonDecoder extends KafkaJsonDeserializer<T> implements Decoder<T> { @Override public T fromBytes(byte[] bytes) { return super.deserialize(null, bytes); } }
KafkaJsonDecoder extends KafkaJsonDeserializer<T> implements Decoder<T> { @Override public T fromBytes(byte[] bytes) { return super.deserialize(null, bytes); } @SuppressWarnings({"rawtypes", "unchecked"})  KafkaJsonDecoder(VerifiableProperties props);  KafkaJsonDecoder(VerifiableProperties props, Class<T> type); }
KafkaJsonDecoder extends KafkaJsonDeserializer<T> implements Decoder<T> { @Override public T fromBytes(byte[] bytes) { return super.deserialize(null, bytes); } @SuppressWarnings({"rawtypes", "unchecked"})  KafkaJsonDecoder(VerifiableProperties props);  KafkaJsonDecoder(VerifiableProperties props, Class<T> type); @Override T fromBytes(byte[] bytes); }
KafkaJsonDecoder extends KafkaJsonDeserializer<T> implements Decoder<T> { @Override public T fromBytes(byte[] bytes) { return super.deserialize(null, bytes); } @SuppressWarnings({"rawtypes", "unchecked"})  KafkaJsonDecoder(VerifiableProperties props);  KafkaJsonDecoder(VerifiableProperties props, Class<T> type); @Override T fromBytes(byte[] bytes);  }