MetricDataMessagePackSerde implements Serde<MetricData> { @Override public Serializer<MetricData> serializer() { return new Ser(); }  @Override void configure(Map<String, ?> configs, boolean isKey); @Override void close(); @Override Serializer<MetricData> serializer(); @Override Deserializer<MetricData> deserializer();  }
@Test(expected = SerializationException.class) public void testSerialize_invalidMetricData() { val invalidMetricDef = new MetricDefinition((String) null); val invalidMetricData = new MetricData(invalidMetricDef, 0.0, Instant.now().getEpochSecond()); serdeUnderTest.serializer().serialize("some-topic", invalidMetricData); }