Log4jSystemConfig extends SystemConfig { public String getSerdeClass(String name) { return get(String.format(SerializerConfig.SERDE_FACTORY_CLASS, name), null); } Log4jSystemConfig(Config config); boolean getLocationEnabled(); String getSystemName(); String getJobName(); String getJobId(); String getSerdeClass(String name); String getStreamSerdeName(String systemName, String streamName);  }
@Test public void testGetSerdeClass() { Map<String, String> map = new HashMap<String, String>(); Log4jSystemConfig log4jSystemConfig = new Log4jSystemConfig(new MapConfig(map)); assertNull(log4jSystemConfig.getSerdeClass("otherName")); map.put("serializers.registry.log4j.class", "someClass"); log4jSystemConfig = new Log4jSystemConfig(new MapConfig(map)); assertEquals("someClass", log4jSystemConfig.getSerdeClass("log4j")); }