, 2018 at 12:08 PM, Jonghyun Lee <jonghy...@gmail.com> wrote:
> Hi Magnus and Jun, do you have any feedback on this?
>
> Since two of the original voters (Becket and Rajini) showed a preference
> for bumping up all request versions, I'll wait till tomorrow and start
> implement
force quotas rather than
> have clients mute themselves. So perhaps we don't need the protocol change?
>
>
> On Sat, May 5, 2018 at 12:49 AM, Jonghyun Lee <jonghy...@gmail.com> wrote:
>
> > Per Rajini's request, I'd like to add one more discussion item.
> Thanks,
>
> Jiangjie (Becket) Qin
>
>
> On Wed, Apr 25, 2018 at 3:19 PM, Jonghyun Lee <jonghy...@gmail.com> wrote:
>
> > Hello,
> >
> > Per Ismael's suggestion, I'd like to get comments from the original
> voters
> > for KIP-219 (Becket, Jun,
plan is to add a method to
AbstractResponse which tells whether or not client should throttle and have
an implementation in each response type based on its version.
Thanks,
Jon
On Mon, Apr 30, 2018 at 9:15 AM, Jonghyun Lee <jonghy...@gmail.com> wrote:
> Hi Rajini,
>
> Thanks for
t,
> perhaps that would be better?
>
> Hi Magnus, It will be good to know what works better for non-Java clients.
>
>
> On Fri, Apr 27, 2018 at 8:34 PM, Jonghyun Lee <jonghy...@gmail.com> wrote:
>
> > Thanks, Becket.
> >
> > Assuming that requiring new c
Hi,
I have been implementing KIP-219. I discussed the interface changes with
Becket Qin and Dong Lin, and we decided to bump up the protocol version of
ApiVersionsRequest and ApiVersionsResponse only, instead of bumping up all
requests/responses that may be throttled, to indicate clients whether
orth mentioning this in the vote
>> thread
>> as well so that the people who voted originally have a chance to comment.
>> Also, we should really get input from developers of Kafka clients
>> (librdkafka, kafka-python, etc.) for this KIP.
>>
>> Ismael
>>
>
Hello,
Per Ismael's suggestion, I'd like to get comments from the original voters
for KIP-219 (Becket, Jun, Rajini) and others about the new interface change
proposed in the discussion thread (
Hello,
KIP-211/KAFKA-4682 introduced a new offset value schema,
OFFSET_COMMIT_VALUE_SCHEMA_v2 in GroupMetadataManager.scala. This new
schema is used for offset commit messages if inter.broker.protocol.version
is set to >= 2.1 AND OffsetAndMetadata does not contain explicit
expireTimestamp (in
