@Test public void testDeserialize_invalidMetricDataBytes() { val actual = serdeUnderTest.deserializer().deserialize("some-topic", "hey".getBytes()); assertNull(actual); }
@Override public Deserializer<MetricData> deserializer() { return new Deser(); }
MetricTankMetricDataMessagePackSerde implements Serde<MetricData> { @Override public Deserializer<MetricData> deserializer() { return new Deser(); } }
MetricTankMetricDataMessagePackSerde implements Serde<MetricData> { @Override public Deserializer<MetricData> deserializer() { return new Deser(); }  }
MetricTankMetricDataMessagePackSerde implements Serde<MetricData> { @Override public Deserializer<MetricData> deserializer() { return new Deser(); }  @Override void configure(Map<String, ?> configs, boolean isKey); @Override void close(); @Override Serializer<MetricData> serializer(); @Override Deserializer<MetricData> deserializer(); }
MetricTankMetricDataMessagePackSerde implements Serde<MetricData> { @Override public Deserializer<MetricData> deserializer() { return new Deser(); }  @Override void configure(Map<String, ?> configs, boolean isKey); @Override void close(); @Override Serializer<MetricData> serializer(); @Override Deserializer<MetricData> deserializer(); static final int DEFAULT_ORG_ID; static final int DEFAULT_INTERVAL; static final String DEFAULT_UNIT; static final String DEFAULT_MTYPE; }