@Override
    public int selectChannel(SerializationDelegate<StreamRecord<T>> record) {
        return random.nextInt(numberOfChannels);
    }
@Test
    void testSelectChannelsInterval() {
        assertSelectedChannelWithSetup(0, 1);

        streamPartitioner.setup(2);
        assertThat(streamPartitioner.selectChannel(serializationDelegate))
                .isGreaterThanOrEqualTo(0)
                .isLessThan(2);

        streamPartitioner.setup(1024);
        assertThat(streamPartitioner.selectChannel(serializationDelegate))
                .isGreaterThanOrEqualTo(0)
                .isLessThan(1024);
    }