Recall: Kafka Issue

Roel Angeles would like to recall the message, "Kafka Issue".

RE: Kafka Issue

Hi Adam and Luke, https://imgur.com/a/ipX0uyw All the best, [lingarogroup.com] Roel Angeles Consultant +63 9157163557 roel.ange...@lingarogroup.com www.lingarogroup.com Lingaro Philippines Inc. 41F Philamlife Tower 8767

Re: [VOTE] KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Hi all, Thanks for the discussion and votes. The KIP passed with: 3 binding votes: Guozhang Wang Bill Bejeck John Roesler 1 non-binding votes: Luke Chen I'll close the vote and start the implementation. Thank you all. Luke On Thu, Aug 19, 2021 at 10:47 PM Bill Bejeck wrote: > Thanks for

Re: [VOTE] KIP-633: Drop 24 hour default of grace period in Streams

Just to clarify, this only affects the JoinWindows APIs. As Matthias mentioned this KIP will still ship partially in 3.0, specifically the APIs and changes to the three aggregation Windows classes: TimeWindows, SlidingWindows, and SessionWindows On Thu, Aug 19, 2021 at 6:14 PM Matthias J. Sax

Re: [VOTE] KIP-633: Drop 24 hour default of grace period in Streams

As discussed on the 3.0 release thread, we discovered a blocker bug for 3.0 that is related to KIP-633. https://issues.apache.org/jira/browse/KAFKA-13216 We propose to partially roll-back KIP-633 API changes to "disable" the new buggy stream-stream join implementation to guard its usage. I

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hi Konstantine. A potential 3.0 blocker was discovered today, https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-13219. The BrokerState metric is not working for KRaft clusters -- it always indicates that the broker is in the "not running" state. A PR is available at

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Given the discussed upgrade path from the current join semantics to the improved join semantics, I think it's best to partly revert KIP-633 for 3.0 release. I prepared a PR for it: https://github.com/apache/kafka/pull/11233 The idea is to stay on `JoinWindows.of().grace()` and not add

Jenkins build is back to stable : Kafka » Kafka Branch Builder » trunk #415

See

[jira] [Created] (KAFKA-13219) BrokerState metric not working for KRaft clusters

Ron Dagostino created KAFKA-13219: - Summary: BrokerState metric not working for KRaft clusters Key: KAFKA-13219 URL: https://issues.apache.org/jira/browse/KAFKA-13219 Project: Kafka Issue

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Konstantine, After a brief chat with Sophie, I just updated the name for KIP-633 to be more descriptive of what is actually happening in the implementation It is changed on the KIP page and the JIRA task title is also updated to be more descriptive https://cwiki.apache.org/confluence/x/Ho2NCg

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hi Matthias, it is possible to still deprecate JoinWindows.of(size) even though the new join semantics is disabled. I just pre-recorded a talk for Kafka Summit Americas where I am recommending a switch to the new APIs instead of the deprecated one starting from 3.0 I would love to be involved in

Jenkins build is back to stable : Kafka » Kafka Branch Builder » 3.0 #112

See

Re: [DISCUSS] KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

Hi Ron, On Sat, Aug 14, 2021, at 11:27 AM, Ron Dagostino wrote: > Hi Kirk -- thanks for the KIP! Having concrete implementations > out-of-the-box will be very helpful. > > > As seen in this diagram, the login callback is executed on the client and > the validate callback is executed on the

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.0 #111

See

Re: [VOTE] KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Thanks for the KIP Luke, this is a very needed change. I'm +1 (binding) -Bill On Tue, Aug 17, 2021 at 5:39 PM Guozhang Wang wrote: > Thanks Luke! +1 as well. > > On Tue, Aug 17, 2021 at 11:42 AM John Roesler wrote: > > > Thanks, Luke! > > > > I'm sorry I missed your discussion thread. The

Re: [DISCUSS] KIP-762 Delete Committed Connect Records

Hi Ryanne, Thanks for the KIP, this is an interesting use case. I agree it's best to have the runtime take care of the deletion. However, I wonder if it would make more sense to have the configuration on connectors instead of the runtime. While Workers perform the deletion, it's very much

Re: KIP-769: Connect API to retrieve connector configuration definitions

Hi Mickael, I'm wondering about the use case here. The motivation section states that "Connect does not provide a way to see what configurations a connector requires. Instead users have to go look at the connector documentation or in the worst case, look directly at the connector source code.",

Re: Kafka Issue

Hi folks You’ll need to host the images externally and send a link. The email server doesn’t send images due to the sheer number of recipients. Try using something like imgur Adam > On Aug 19, 2021, at 2:18 AM, Roel Angeles > wrote: > >  > Hi Luke, > > Resending the screenshot. > > >

KIP-769: Connect API to retrieve connector configuration definitions

Hi, I've created KIP-769 to expose connector configuration definitions in the Connect API https://cwiki.apache.org/confluence/display/KAFKA/KIP-769%3A+Connect+API+to+retrieve+connector+configuration+definitions Please take a look and let me know if you have any feedback. Thanks

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #414

See

Re: Failed Unit testings in ReassignPartitionsIntegrationTest

Hi Luke, Thanks for your suggestion! I will try to test in in VM/Docker. BTW, may I know the exact java/scala version used in your local env (e.g. jdk1.8.0_172 / Scala 2.13.1)? Just would like to rule out this factor. Best, Yanwen > On Aug 18, 2021, at 11:35 PM, Luke Chen wrote: > > Hi

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #108

See

RE: Kafka Issue

Hi Luke, Resending the screenshot. [cid:image001.png@01D7950D.0DD14150] [cid:image004.png@01D7950D.5FCC3190] Changes from [cid:image005.png@01D7950D.5FCC3190] to [cid:image006.png@01D7950D.5FCC3190] All the best, [lingarogroup.com] Roel Angeles Consultant +63 9157163557

Re: Kafka Issue

Hi Roel, I'm not sure if it's just me or not, but I can't see your screenshots, so I don't know what happened. Thanks. Luke On Wed, Aug 18, 2021 at 10:12 PM Jason Kamdon wrote: > Hi Team, > > > > Can we have an update regarding below concern. > > > > > > Thanks! > > > > Regards, > > [image:

Re: Failed Unit testings in ReassignPartitionsIntegrationTest

Hi Yanwen, Welcome to Kafka! Usually, we posted flaky tests on JIRA when we saw failed tests on Jenkins build, either on trunk build, or PR build. What you mentioned 2 (flaky) failed tests have not failed in Jenkins for a long time (since build # 364, check below link). Besides, it also passed in