DataSiftWriter { @VisibleForTesting @SuppressWarnings("checkstyle:designforextension") protected boolean shouldRead() { return processRead; } DataSiftWriter(); static void main(final String[] args);  }
@Test public void should_set_should_read_default_to_true() { DataSiftWriter dsw = new DataSiftWriter(); dsw.waitOnKafka = false; assertTrue(dsw.shouldRead()); }