Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

2020-08-29 Thread John Roesler
Hi Navinder, Thanks for the ping. Yes, that all sounds right to me. The name “RESTORING_GLOBAL” sounds fine, too. I think as far as warnings go, we’d just propose to mention it in the javadoc of the relevant methods that the given topics should be compacted. Thanks! -John On Fri, Aug 28, 2

Request to subscribe to kafka mailing list

2020-08-29 Thread SaiTeja Ramisetty
Regards, SaiTeja - Data Engineer

Permission to create KIP

2020-08-29 Thread sorin
Hi guys I just wanted to propose an addition to the Consumer API to add a new poll method which would also accept a collection of paused partitions to automatically do the actions that are needed to resume serving messages for the provided partitions. If this is not the way to go for making suc

Re: [DISCUSS] KIP-631: The Quorum-based Kafka Controller

2020-08-29 Thread Unmesh Joshi
>>>Can you repeat your questions about broker leases? The LeaseStartTimeMs is expected to be the broker's 'System.currentTimeMillis()' at the point of the request. The active controller will add its lease period to this in order to compute the LeaseEndTimeMs. I think the use of LeaseStart