[jira] [Created] (KAFKA-10209) fix flaky connect_rest_test.py

Chia-Ping Tsai created KAFKA-10209: -- Summary: fix flaky connect_rest_test.py Key: KAFKA-10209 URL: https://issues.apache.org/jira/browse/KAFKA-10209 Project: Kafka Issue Type: Bug

回复：[ANNOUNCE] New committer: Xi Hu

Congrats, Xi! Feyman -- 发件人：Satish Duggana 发送时间：2020年6月29日(星期一) 13:37 收件人：dev 主　题：Re: [ANNOUNCE] New committer: Xi Hu Congratulations Xi! On Mon, Jun 29, 2020 at 10:41 AM Konstantine Karantasis wrote: > > Congrats Xi! > >

Re: [ANNOUNCE] New committer: Xi Hu

Congratulations Xi! On Mon, Jun 29, 2020 at 10:41 AM Konstantine Karantasis wrote: > > Congrats Xi! > > -Konstantine > > On Sat, Jun 27, 2020 at 7:13 PM Matt Wang wrote: > > > Congratulations ~ > > > > > > -- > > > > Best, > > Matt Wang > > > > > > On 06/26/2020 23:06，David Jacot wrote： > >

Re: [ANNOUNCE] New committer: Boyang Chen

Congratulations Boyang! On Fri, Jun 26, 2020 at 8:36 PM David Jacot wrote: > > Congrats, Boyang! > > On Thu, Jun 25, 2020 at 1:57 PM Viktor Somogyi-Vass > wrote: > > > Congrats :) > > > > On Thu, Jun 25, 2020 at 12:28 AM Liquan Pei wrote: > > > > > Congrats! > > > > > > On Wed, Jun 24, 2020 at

Re: [ANNOUNCE] New committer: Xi Hu

Congrats Xi! -Konstantine On Sat, Jun 27, 2020 at 7:13 PM Matt Wang wrote: > Congratulations ~ > > > -- > > Best, > Matt Wang > > > On 06/26/2020 23:06，David Jacot wrote： > Congrats! > > On Thu, Jun 25, 2020 at 4:08 PM Hu Xi wrote: > > Thank you, everyone. It is my great honor to be a part of

Re: [VOTE] KIP-629: Use racially neutral terms in our codebase

+1 (binding) On Fri, Jun 26, 2020 at 3:10 AM Benny Lee wrote: > > > > From: Tom Bentley > Sent: Friday, 26 June 2020 7:45 PM > To: dev@kafka.apache.org > Subject: Re: [VOTE] KIP-629: Use racially neutral terms in our codebase > > +1 (non-binding) > > On Fri,

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hi John, Thank you for the positive feedback! The meaningful discussions we had on the mailing list helped me understand what needed to be done. I am definitely open to any further suggestions on this. Before I updated the KIP, I just had one question, is it fine to have it for KeyValueStore or

Re: [DISCUSS] KIP-578: Add configuration to limit number of partitions

Hey Gokul, thanks for the reply. It is true that the Metadata API will call CreateTopic under the cover. The key guarantee we need to provide is to properly propagate the exact error code to the original client. So either we are going to introduce a new error code or reuse an existing one, the

Jenkins build is back to normal : kafka-2.6-jdk8 #63

See

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

Sorry my bad. Found it. Prefix used to override {@link KafkaConsumer consumer} configs for the global consumer client from * the general consumer client configs. The override precedence is the following (from highest to lowest precedence): * 1. global.consumer.[config-name].. public static

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

Hi John, Thanks for your feedback.  1. I think there is some confusion on my first point, the enum I am sure we can use the same one but the external config which controls the resetting in global stream thread either we can the same one which users use for source topics(StreamThread) or we can

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Woah, this is great, Sagar! I think this API looks really good. I'm curious if anyone else has any concern. For my part, I think this will work just fine. People might face tricky bugs getting their key serde and their prefix serde "aligned", but I think the API makes it pretty obvious what has

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hi John, I took some time out and as we discussed, looked to implement these changes. Most of these changes are for demonstrative purposes but I thought I will share. I added the new prefixSeek method at the KeyValueStore interface level:

Potential Improvement for Kafka Producer

Hi All, Not sure if this is the right channel and thread to ask, but would like to discuss a potential improvement to Java Kafka Producer. ``` Currently the Kafka Producer is able to identify unavailable partitions and avoid routing messages to them, but the definition of an unavailable