chore(timeout): parameterize pollTimeout

[contacthari21]

Fixes Issue #216

[Crim]

Is there a way to pass this value thru from the UI when defining a cluster or topic?

[contacthari21]

Isn't this more related to Consumer configuration and not specific to a cluster/topic configuration?

[Crim]

Isn't this more related to Consumer configuration and not specific to a cluster/topic configuration?

I think you're correct, but there still needs to be some way to allow a user to define what that value should be, either via a config property, or via the UI (presumably tied to the cluster definition?, but maybe somewhere else, unsure)

[contacthari21]

I think you're correct, but there still needs to be some way to allow a user to define what that value should be, either via a config property, or via the UI (presumably tied to the cluster definition?, but maybe somewhere else, unsure)

Ya, passing this value from UI would be another issue to be worked on if I think off. But what I could do is update the View table with getter and setters for pollTimeout and then have it passed as part of WebKafkaConsumerFactory's createClientConfig in this block below which will take care of the API part .. Does it sound fine ?
// Build the client config.
final ClientConfig.Builder clientConfigBuilder = ClientConfig.newBuilder()
.withTopicConfig(topicConfig)
.withConsumerId(consumerId)
.withPartitions(view.getPartitionsAsSet())
.withMaxResultsPerPartition(view.getResultsPerPartition());

I see that WebKafkaConsumerFactory creates the web consumer client by getting the values from View.

[contacthari21]

@Crim Should I update the View table and the Factory and open a PR. I am unable to start up the docker image on localhost in my local, will you be able to run through it after I send in this PR to make sure it is working BAU?