You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by Richard Yu <ri...@transwarp.io> on 2018/07/09 04:17:18 UTC

[DISCUSS] KIP-335 Consider configurations for Kafka Streams

Hi all,


Eversince KIP-266 was concluded, there has been a pressing need to migrate Kafka Streams as well. For the link, please click here:


https://cwiki.apache.org/confluence/display/KAFKA/KIP-335%3A+Consider+configurations+for+KafkaStreams


Thanks,
Richard Yu

Re: [DISCUSS] KIP-335 Consider configurations for Kafka Streams

Posted by "Matthias J. Sax" <ma...@confluent.io>.

Moved this KIP into status "inactive". Feel free to resume and any time.

-Matthias

On 7/19/18 10:57 AM, Matthias J. Sax wrote:
> Thanks for the KIP.
> 
> I just double checked the code. It seems that `retries` and
> `retries.backoff.ms` is only used in `GlobalStateManagerImpl` any longer
> to catch a timeout exception and retry.
> 
> Thus, it seems reasonable to me to deprecate those configs and rewrite
> `GlobalStateManager` accordingly.
> 
> It makes also sense to me, to introduce a global config to set the
> blocking timeout.
> 
> Note, that there is already `poll.ms` that is passed into `poll()` as
> timeout value. Thus, the question raises, if `poll.ms` should be kept or
> replaced?
> 
> What name do you suggest for the new config?
> 
> I also think, that the section about compatibility should be more detailed.
> 
> 
> 
> -Matthias
> 
> On 7/8/18 9:25 PM, Richard Yu wrote:
>>  Hi Matthias,
>> It would be nice to get your opinions on this.
>>
>>     On Monday, July 9, 2018, 12:17:33 PM GMT+8, Richard Yu <ri...@transwarp.io> wrote:  
>>  
>>  Hi all,
>>
>>
>> Eversince KIP-266 was concluded, there has been a pressing need to migrate Kafka Streams as well. For the link, please click here:
>>
>>
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-335%3A+Consider+configurations+for+KafkaStreams
>>
>>
>> Thanks,
>> Richard Yu  
>>
>

Re: [DISCUSS] KIP-335 Consider configurations for Kafka Streams

Posted by "Matthias J. Sax" <ma...@confluent.io>.

Thanks for the KIP.

I just double checked the code. It seems that `retries` and
`retries.backoff.ms` is only used in `GlobalStateManagerImpl` any longer
to catch a timeout exception and retry.

Thus, it seems reasonable to me to deprecate those configs and rewrite
`GlobalStateManager` accordingly.

It makes also sense to me, to introduce a global config to set the
blocking timeout.

Note, that there is already `poll.ms` that is passed into `poll()` as
timeout value. Thus, the question raises, if `poll.ms` should be kept or
replaced?

What name do you suggest for the new config?

I also think, that the section about compatibility should be more detailed.

-Matthias

On 7/8/18 9:25 PM, Richard Yu wrote:
>  Hi Matthias,
> It would be nice to get your opinions on this.
> 
>     On Monday, July 9, 2018, 12:17:33 PM GMT+8, Richard Yu <ri...@transwarp.io> wrote:  
>  
>  Hi all,
> 
> 
> Eversince KIP-266 was concluded, there has been a pressing need to migrate Kafka Streams as well. For the link, please click here:
> 
> 
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-335%3A+Consider+configurations+for+KafkaStreams
> 
> 
> Thanks,
> Richard Yu  
>

Re: [DISCUSS] KIP-335 Consider configurations for Kafka Streams

Posted by Richard Yu <yr...@yahoo.com.INVALID>.

 Hi Matthias,
It would be nice to get your opinions on this.

    On Monday, July 9, 2018, 12:17:33 PM GMT+8, Richard Yu <ri...@transwarp.io> wrote:  
 
 Hi all,


Eversince KIP-266 was concluded, there has been a pressing need to migrate Kafka Streams as well. For the link, please click here:


https://cwiki.apache.org/confluence/display/KAFKA/KIP-335%3A+Consider+configurations+for+KafkaStreams


Thanks,
Richard Yu