@Test
public void testAppendMessages() throws Exception {

	String topic = "order_new";
	Tpp tpp = new Tpp(topic, 0, true);
	Collection<MessageRawDataBatch> batches = new ArrayList<>();
	// TODO mock data
	ByteBuf rawData = Unpooled.buffer();
	MessageRawDataBatch batch = new MessageRawDataBatch(topic, Arrays.asList(1), rawData);
	batches.add(batch);
	s.appendMessages(tpp, batches);
}