public long getBytesOutCounter() {
        return bytesOutCounter.longValue();
    }
@Test
    public void testGetBytesOutCounter() {
        stats.bytesOutCounter = 1L;
        consumer.updateStats(stats);
        assertEquals(consumer.getBytesOutCounter(), 1L);
    }