public static <T> Write<T> write() {
    return new AutoValue_SnsIO_Write.Builder<T>()
        .setClientConfiguration(ClientConfiguration.builder().build())
        .build();
  }
@Test
  public void testSkipTopicValidation() {
    PCollection<String> input = mock(PCollection.class);
    when(input.getPipeline()).thenReturn(p);
    when(input.apply(any(PTransform.class))).thenReturn(mock(PCollection.class));

    Write<String> snsWrite =
        SnsIO.<String>write().withPublishRequestBuilder(msg -> requestBuilder(msg, topicArn));

    snsWrite.expand(input);
    verify(sns, times(0)).getTopicAttributes(any(Consumer.class));
  }