@Test
@Parameters(method = "provideFactoryInstances")
public void smokeTestWebClient_noFilters_allPartitions(final WebKafkaConsumerFactory factory) {

    final int resultsPerPartition = 5;
    // Create default view.
    final View view = createDefaultView(topic1);
    // Set results per partition to 5
    view.setResultsPerPartition(resultsPerPartition);
    // Create SessionId
    final SessionIdentifier sessionId = SessionIdentifier.newWebIdentifier(12L, "MySession");
    // Ok lets see what happens
    try (final WebKafkaConsumer webKafkaConsumer = factory.createWebClient(view, new ArrayList<>(), sessionId)) {
        // Validate we got something back
        assertNotNull(webKafkaConsumer);
        final List<KafkaResult> results = consumeAllResults(webKafkaConsumer, resultsPerPartition);
        assertEquals( "Should have a total of 20 records", 20, results.size());
        // Validate is from partitions 0 and 1
        for (final KafkaResult kafkaResult: results) {
            assertTrue("Should be from partition 0 or 1", kafkaResult.getPartition() == 0 || kafkaResult.getPartition() == 1);
        }
    }
}