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 > <richard...@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 >
signature.asc
Description: OpenPGP digital signature
