@Test public void genericConstruct() throws Exception { VerifiableProperties props = new VerifiableProperties(); KafkaJsonDecoder<String> decoder = new KafkaJsonDecoder<String>(props, String.class); assertEquals(String.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);  }