[jira] [Created] (KAFKA-10457) JsonConverter.toConnectData trims BigInteger to Double for schema-less case

2020-09-01 Thread Oleksandr Diachenko (Jira)
Oleksandr Diachenko created KAFKA-10457: --- Summary: JsonConverter.toConnectData trims BigInteger to Double for schema-less case Key: KAFKA-10457 URL: https://issues.apache.org/jira/browse/KAFKA-10457

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #39

2020-09-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10444: Configure PR builds via Jenkinsfile (#9238) -- [...truncated 3.25 MB...] org.apache.kafka.streams.test.OutputVerifierTest

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #37

2020-09-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10020: Create a new version of a scala Serdes without name clash (KIP-616) (#8955) [github] KAFKA-10444: Configure PR builds via Jenkinsfile (#9238)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #38

2020-09-01 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10020: Create a new version of a scala Serdes without name clash (KIP-616) (#8955) -- [...truncated 3.25 MB...]

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

2020-09-01 Thread Colin McCabe
Hi Ron, Thanks. We can wait for Rajini's reply to finalize this, but for now I guess that will unblock the PR at least. If we do decide we want the restriction we can do a follow-on PR. It's good to see this API moving forward! best, Colin On Tue, Sep 1, 2020, at 12:55, Ron Dagostino

Re: New PR builder Jenkins job

2020-09-01 Thread Ismael Juma
Thanks David! This is very helpful. Ismael On Tue, Sep 1, 2020, 3:15 PM David Arthur wrote: > Following the migration to the new ci-builds.apache.org, our existing PR > builder jobs stopped working. This was due to the removal of a github > plugin which we relied on. While looking into how to

New PR builder Jenkins job

2020-09-01 Thread David Arthur
Following the migration to the new ci-builds.apache.org, our existing PR builder jobs stopped working. This was due to the removal of a github plugin which we relied on. While looking into how to fix this, we decided to take the opportunity to switch over to a declarative Jenkinsfile for the

[jira] [Created] (KAFKA-10456) wrong description in kafka-console-producer.sh help

2020-09-01 Thread danilo batista queiroz (Jira)
danilo batista queiroz created KAFKA-10456: -- Summary: wrong description in kafka-console-producer.sh help Key: KAFKA-10456 URL: https://issues.apache.org/jira/browse/KAFKA-10456 Project:

Re: [VOTE] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

2020-09-01 Thread John Roesler
Hello again, all! After Leah proposed KIP-659, we realized that it's not possible to provide a correct implicit TimeWindowedSerde, so we decided to drop it from KIP-616. See https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=153816723=15=14 And here's the discussion

Re: [DISCUSS] KIP-663: API to Start and Shut Down Stream Threads and to Request Closing of Kafka Streams Clients

2020-09-01 Thread Walker Carlson
Hi Bruno, I read through your updated KIP and it looks good to me. I agree with adding the metric to keep track of crashed streams in replace of a list of dead streams. best, Wlaker :) On Tue, Sep 1, 2020 at 1:05 PM Bruno Cadonna wrote: > Hi John, > > your proposal makes sense! I will update

Kafka Meetup hosted Online, Wednesday 5:00pm, Sep 2nd, 2020

2020-09-01 Thread Guozhang Wang
Hello folks, The Bay Area Kafka meetup will continue to be hosted online this month, tomorrow (Sep 2nd) at 5:00pm. This time we will have guest speakers from Twitter to talk about their journey to adopt Apache Kafka. *RSVP*: https://www.meetup.com/KafkaBayArea/events/272643868/ *Date* 5:00pm,

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

2020-09-01 Thread Bill Bejeck
Thanks for the KIP! This is a great addition to the streams API. +1 (binding) -Bill On Tue, Sep 1, 2020 at 12:33 PM Sagar wrote: > Hi All, > > Bumping the thread again ! > > Thanks! > Sagar. > > On Wed, Aug 5, 2020 at 12:08 AM Sophie Blee-Goldman > wrote: > > > Thanks Sagar! +1 (non-binding)

Re: [DISCUSS] KIP-663: API to Start and Shut Down Stream Threads and to Request Closing of Kafka Streams Clients

2020-09-01 Thread Bruno Cadonna
Hi John, your proposal makes sense! I will update the KIP. Best, Bruno On 01.09.20 17:31, John Roesler wrote: Hello Bruno, Thanks for the update! The KIP looks good to me; I only have a grammatical complaint about the proposed metric name. "Died" is a verb, the past tense of "to die", but

Re: [VOTE] KIP-554: Add Broker-side SCRAM Config API

2020-09-01 Thread Ron Dagostino
Hi Colin. I've removed that requirement from the KIP and updated the PR accordingly. Ron On Fri, Aug 28, 2020 at 2:27 PM Colin McCabe wrote: > Hi Ron, > > Thanks for the update. I agree with all of these changes, except I think > we should discuss this one further: > > On Wed, Aug 26, 2020,

[jira] [Created] (KAFKA-10455) Probing rebalances are not guaranteed to be triggered by non-leader members

2020-09-01 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-10455: --- Summary: Probing rebalances are not guaranteed to be triggered by non-leader members Key: KAFKA-10455 URL: https://issues.apache.org/jira/browse/KAFKA-10455

Re: [DISCUSS] KIP-666: Add Instant-based methods to ReadOnlySessionStore

2020-09-01 Thread Jorge Esteban Quilcate Otoya
Thanks Sophie! > one nit: you missed updating the startTime long to Instant in both appearances of the fetchSession(key, startTime, sessionEndTime) method. Agreed. I'm fixing this on the KIP. > Also, I think by "startTime" you actually meant "earliestSessionEndTime". Given the implementation

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

2020-09-01 Thread Sagar
Hi All, Bumping the thread again ! Thanks! Sagar. On Wed, Aug 5, 2020 at 12:08 AM Sophie Blee-Goldman wrote: > Thanks Sagar! +1 (non-binding) > > Sophie > > On Sun, Aug 2, 2020 at 11:37 PM Sagar wrote: > > > Hi All, > > > > Just thought of bumping this voting thread again to see if we can

Re: [DISCUSS] KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

2020-09-01 Thread John Roesler
Hi Leah and Sophie, Sorry for the delayed response. You can pass in pre-instantiated (and therefore arbirarily constructed) deserializers to the KafkaConsumer. However, this doesn't mean we should drop the configs. The same argument for dropping the configs implies that the consumer shouldn't

Re: Request to Add in Contributor list

2020-09-01 Thread John Roesler
Hi Sharath, Please forgive me if this is a mistake, but I think I've just granted this permission for your username "DOJI". Do you need access as "DOJI45"? Thanks, -John On Tue, 2020-09-01 at 16:11 +0530, Sharath Bhat wrote: > Hi TeamPlease guide me on how I can request contributor access for

Re: Need contributor access to Jira

2020-09-01 Thread John Roesler
Hi Sandeep, I've added you to the contributors group in Jira. Thanks for your interest in Apache Kafka! Thanks, -John On Tue, 2020-09-01 at 16:13 +0530, Sandeep Kumar wrote: > Hi Team , > > Please guide me how I can request for the contributor access for jira so > that I can assign some jira

Re: Request to Add in Contributor list

2020-09-01 Thread John Roesler
Hi Sharath, I've added you to the contributor group in Jira. Thanks for your interest in Apache Kafka! Thanks, -John On Tue, 2020-09-01 at 17:22 +0530, Sharath Bhat wrote: > Hi TeamPlease guide me on how I can request contributor access for jira so > that i can assign some jira tickets to

Re: [DISCUSS] KIP-667: Remove deprecated methods from ReadOnlyWindowStore

2020-09-01 Thread John Roesler
Hi all, Thanks for bringing this up, Jorge! I'm not sure if we have a documented rule; I seem to recall having had the same discussion for 2.0. My personal suggestion would be to have a deprecation period of at least one year, and beyond that to weigh how good we feel about removing each

Request to Add in Contributor list

2020-09-01 Thread Sharath Bhat
Hi TeamPlease guide me on how I can request contributor access for jira so that i can assign some jira tickets to myself and contribute to the kafka community. JIRA Username: *DOJI* Email: *sharathbha...@gmail.com * Full Name : *Sharath Bhat* Regards Sharath Bhat

Request to Add in Contributor list

2020-09-01 Thread Sharath Bhat
Hi TeamPlease guide me on how I can request contributor access for jira so that i can assign some jira tickets to myself and contribute to the kafka community. JIRA Username: *DOJI45* Email: *sharathbha...@gmail.com * Full Name : *Sharath Bhat* Regards Sharath Bhat

Need contributor access to Jira

2020-09-01 Thread Sandeep Kumar
Hi Team , Please guide me how I can request for the contributor access for jira so that I can assign some jira tickets to myself and contribute to the kafka community. Username: sndp2693 Email: sndp2...@gmail.com Full Name: Sandeep Kumar Thanks and Regards Sandeep

Re: [DISCUSS] KIP-663: API to Start and Shut Down Stream Threads and to Request Closing of Kafka Streams Clients

2020-09-01 Thread John Roesler
Hello Bruno, Thanks for the update! The KIP looks good to me; I only have a grammatical complaint about the proposed metric name. "Died" is a verb, the past tense of "to die", but in the expression,"x stream threads", x should be an adjective. To be fair, "died" is also the past participle of

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

2020-09-01 Thread Unmesh Joshi
>>Yes, I agree that the lease timeout on the controller side should be reset.The alternative would be to track the lease as hard state rather than soft state, but I think that is not really >> >> needed, and would result in more log entries. On the related note, I think it will be good to add some

Re: [DISCUSS] KIP-654 Aborting Transaction with non-flushed data should throw a non-fatal Exception

2020-09-01 Thread Gokul Srinivas
Matthias, Sophie, Jason, Took another pass at understanding the internals and it seems to me like we should be extending the `ApiException` rather than the `RetriableException`. The check in question = Do we abort any undrained batches that are present on this

Re: Request to get added to Jira assignees

2020-09-01 Thread Mickael Maison
Done. Thanks for your interest in Apache Kafka! On Tue, Sep 1, 2020 at 12:35 PM rupesh patel wrote: > > Hi Team, > > > Please add me to the JIRA Assignee list. I would like to start contributing. > > Username: rupeshkumarpatel02 > > email id: rupeshkumarpate...@hotmail.com > > Thanks, > Rupesh

Request to get added to Jira assignees

2020-09-01 Thread rupesh patel
Hi Team, Please add me to the JIRA Assignee list. I would like to start contributing. Username: rupeshkumarpatel02 email id: rupeshkumarpate...@hotmail.com Thanks, Rupesh

[jira] [Created] (KAFKA-10454) Kafka Streams Stuck in infinite REBALANCING loop when stream <> table join partitions don't match

2020-09-01 Thread Levani Kokhreidze (Jira)
Levani Kokhreidze created KAFKA-10454: - Summary: Kafka Streams Stuck in infinite REBALANCING loop when stream <> table join partitions don't match Key: KAFKA-10454 URL:

Re: [DISCUSS] KIP-663: API to Start and Shut Down Stream Threads and to Request Closing of Kafka Streams Clients

2020-09-01 Thread Bruno Cadonna
Hi, I updated the KIP with the feedback so far. I removed the API to close the Kafka Streams client asynchronously, since it should be possible to avoid the deadlock with the existing method and without a KIP. Please have a look at the updated KIP and let me know what you think.

Re: Request to Add in Contributor list

2020-09-01 Thread Mickael Maison
Done. Thanks for your interest in Apache Kafka! On Tue, Sep 1, 2020 at 10:42 AM Mani Jindal wrote: > > Hi Team > > Please guide me how can i request for the contributor access for jira so > that i can assign some jira tickets to myself and contribute to the kafka > community. > > JIRA Username:

Request to Add in Contributor list

2020-09-01 Thread Mani Jindal
Hi Team Please guide me how can i request for the contributor access for jira so that i can assign some jira tickets to myself and contribute to the kafka community. JIRA Username: *manijndl77* Email: *manijn...@gmail.com * Full Name : *Mani Jindal* Thanks and Regards Mani Jindal