@Nonnull
    public static <T> Sink<T> remoteList(@Nonnull String listName, @Nonnull ClientConfig clientConfig) {
        return fromProcessor("remoteListSink(" + listName + ')', writeRemoteListP(listName, clientConfig));
    }
@Test
    public void remoteList() {
        // Given
        populateList(srcList);

        // When
        Sink<Object> sink = Sinks.remoteList(sinkName, clientConfig);

        // Then
        p.readFrom(Sources.list(srcName)).writeTo(sink);
        execute();
        assertEquals(itemCount, remoteHz.getList(sinkName).size());
    }