Log4jSystemConfig extends SystemConfig { public String getStreamSerdeName(String systemName, String streamName) { StreamConfig streamConfig = new StreamConfig(this); Optional<String> option = streamConfig.getStreamMsgSerde(new SystemStream(systemName, streamName)); return option.isPresent() ? option.get() : 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 testGetSerdeName() { Map<String, String> map = new HashMap<String, String>(); map.put("systems.mockSystem.samza.msg.serde", "systemSerde"); Log4jSystemConfig log4jSystemConfig = new Log4jSystemConfig(new MapConfig(map)); assertNull(log4jSystemConfig.getStreamSerdeName("mockSystem", "mockStream")); map.put("systems.mockSystem.streams.mockStream.samza.msg.serde", "streamSerde"); log4jSystemConfig = new Log4jSystemConfig(new MapConfig(map)); assertEquals("streamSerde", log4jSystemConfig.getStreamSerdeName("mockSystem", "mockStream")); }