@Override
    public int selectChannel(SerializationDelegate<StreamRecord<T>> record) {
        throw new UnsupportedOperationException(
                "Broadcast partitioner does not support select channels.");
    }
@Test
    void testSelectChannels() {
        assertThatThrownBy(() -> streamPartitioner.selectChannel(serializationDelegate))
                .as("Broadcast selector does not support select channels.")
                .isInstanceOf(UnsupportedOperationException.class);
    }