@Ignore
@Test
public void testConsumerOffsetSchemaRecordListMapper() throws IOException {

	mapper = ElasticSearchConsumerOffsetMetricsService.getMetricObjectMapper(new ConsumerOffsetRecordList.IndexSerializer(), new ConsumerOffsetRecordList.Deserializer());
	Long cTime = System.currentTimeMillis();
	ConsumerOffsetMetric record1 = new ConsumerOffsetMetric("metric", "topic", cTime, 0.0, defaultTags);
	ConsumerOffsetRecordList recordList = new ConsumerOffsetRecordList(Arrays.asList(record1), ElasticSearchUtils.HashAlgorithm.fromString("MD5"));
	String serialized = mapper.writeValueAsString(recordList);
	String[] lines = serialized.split("\\r?\\n");
	String expectedIndexName = getExpectedIndexName();
	JsonNode root = mapper.readTree(lines[0]);
	String actualIndexName = root.get("index").get("_index").asText();
	assertEquals(expectedIndexName, actualIndexName);
	String expectedSerializedMetric =
			"{\"metric\":\"metric\",\"topic\":\"topic\",\"value\":\"0.0\",\"ts\":\"" + cTime + "\",\"tags\":\"{\\\"key1\\\":\\\"val1\\\",\\\"key2\\\":\\\"val2\\\"}\"}";
	assertEquals(expectedSerializedMetric, lines[1]);
}