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

    final int resultsPerPartition = 5;
    // Create default view.
    final View view = createDefaultView(topic1);
    // Set results per partition to 5
    view.setResultsPerPartition(resultsPerPartition);
    // Set to only read partition 1
    view.setPartitions("1");
    // 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);
        // Consume everything
        final List<KafkaResult> results = consumeAllResults(webKafkaConsumer, resultsPerPartition);
        assertEquals("Should have 10 records", 10, results.size());
        // Validate is from partition 1 only
        for (final KafkaResult kafkaResult: results) {
            assertEquals("Should be from partition 1", 1, kafkaResult.getPartition());
        }
    }
}