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

Hey Konstantine, A javadocs ticket of ours was demoted to a non-blocker earlier this week due to lack of action, but I now have a PR ready and under review. It's picking up some essential followup that was missed during the implementation of KIP-633 and is pretty essential. I tagged you on the

[jira] [Created] (KAFKA-13129) Fix broken system tests relate to the ConfigCommand change

Luke Chen created KAFKA-13129: - Summary: Fix broken system tests relate to the ConfigCommand change Key: KAFKA-13129 URL: https://issues.apache.org/jira/browse/KAFKA-13129 Project: Kafka Issue

[jira] [Created] (KAFKA-13128) Flaky Test StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemovingStreamThread

A. Sophie Blee-Goldman created KAFKA-13128: -- Summary: Flaky Test StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemovingStreamThread Key: KAFKA-13128 URL:

[jira] [Created] (KAFKA-13127) Fix stray partition lookup logic

Jason Gustafson created KAFKA-13127: --- Summary: Fix stray partition lookup logic Key: KAFKA-13127 URL: https://issues.apache.org/jira/browse/KAFKA-13127 Project: Kafka Issue Type: Bug

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

Thanks for raising this John. While we are working to eliminate the existing blockers I think it would be great to use this time in order to test the upgrade path that you mention. Before we approve a release candidate (once such a RC is generated) we should confirm that the upgrade works as

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

Hello Konstantine, Someone just called to my attention that KAFKA-12724 had not been marked as a 3.0 blocker. We never added 2.8 to the Streams upgrade system test suite. This isn't a blocker in that it is a problem, but we should make sure that Streams is actually upgradable before releasing

Build failed in Jenkins: Kafka » Kafka Branch Builder » 2.8 #55

See Changes: -- [...truncated 465733 lines...] [2021-07-22T22:25:04.818Z] KafkaZkClientTest > testZNodeChangeHandlerForDataChange() STARTED [2021-07-22T22:25:04.818Z]

[jira] [Created] (KAFKA-13126) Overflow in joinGroupTimeoutMs when max.poll.interval.ms is MAX_VALUE leads to missing rebalances

A. Sophie Blee-Goldman created KAFKA-13126: -- Summary: Overflow in joinGroupTimeoutMs when max.poll.interval.ms is MAX_VALUE leads to missing rebalances Key: KAFKA-13126 URL:

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #168

See Changes: [Manikumar Reddy] KAFKA-12985: Upgrade jetty to 9.4.42 (#10919) [Manikumar Reddy] MINOR: checkstyle version upgrade: 8.20 -> 8.36.2 (#10656) --

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #54

See

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

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #354

See Changes: -- [...truncated 486476 lines...] [2021-07-22T19:36:30.313Z] TopicCommandIntegrationTest > testDescribeWhenTopicDoesntExist() PASSED

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Hi Ivan, Sorry for the late amendment, but I was just reviewing the KIP again for your vote thread, and it struck me that, if this is a stateful operation, we need a few more overloads. Following the example from the other stateful windowed operators, we should have: distinct() distinct(Named)

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

Hi Ivan, Thanks for the reply. 1. I think I might have gotten myself confused. I was thinking of this operation as stateless, but now I'm not sure what I was thinking... This operator has to be stateful, right? In that case, I agree that comparing serialized values seems to be way to do it. 2.

[jira] [Resolved] (KAFKA-12985) CVE-2021-28169 - Upgrade jetty to 9.4.41

[ https://issues.apache.org/jira/browse/KAFKA-12985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-12985. --- Fix Version/s: 2.8.1 2.7.2 3.0.0 Resolution: Fixed >

Re: [VOTE] KIP-763: Range queries with open endpoints

Thank you, Patrick, +1 (binding) from me as well! Thanks, -John On Thu, 2021-07-22 at 10:40 +0200, Bruno Cadonna wrote: > Hi Patrick, > > Thank you for the KIP! > > +1 (binding) > > Best, > Bruno > > On 22.07.21 03:47, Luke Chen wrote: > > Hi Patrick, > > I like this KIP! > > > > +1

Re: Jira contributor access

Done, thanks for your interest in Kafka! On Thu, Jul 22, 2021 at 10:37 AM Knowles Atchison Jr wrote: > Requesting Jira contributor access. > > Username: katchison >

Re: [DISCUSS] KIP-714: Client metrics and observability

On Wed, Jul 21, 2021 at 6:17 PM Colin McCabe wrote: > On Tue, Jun 29, 2021, at 07:22, Magnus Edenhill wrote: > > Den tors 17 juni 2021 kl 00:52 skrev Colin McCabe : > > > A few critiques: > > > > > > - As I wrote above, I think this could benefit a lot by being split > into > > > several RPCs. A

Jira contributor access

Requesting Jira contributor access. Username: katchison

[GitHub] [kafka-site] hrittikhere opened a new pull request #364: Add p3r (https://www.p3r.one/) to the list of the "Powered By ❤️"

hrittikhere opened a new pull request #364: URL: https://github.com/apache/kafka-site/pull/364 [p3r](https://www.p3r.one/) uses Kafka as part of our Kubernetes Platform. We deliver it alongside Linkerd for development teams building event-based microservices. @hachikuji could you

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Hi Rohan, Thank you for the KIP! I agree that the KIP is well-motivated. What is not very clear is the metadata like type, group, and tags of the metrics. For example, there is not application-id tag in Streams and there is also no producer-id tag. The clients, i.e., producer, admin,

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #353

See

[jira] [Resolved] (KAFKA-13069) Add magic number to DefaultKafkaPrincipalBuilder.KafkaPrincipalSerde

[ https://issues.apache.org/jira/browse/KAFKA-13069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino resolved KAFKA-13069. --- Resolution: Invalid Flexible fields are sufficient as per KIP-590 VOTE email thread, so a

Re: [VOTE] KIP-763: Range queries with open endpoints

Hi Patrick, Thank you for the KIP! +1 (binding) Best, Bruno On 22.07.21 03:47, Luke Chen wrote: Hi Patrick, I like this KIP! +1 (non-binding) Luke On Thu, Jul 22, 2021 at 7:04 AM Matthias J. Sax wrote: Thanks for the KIP. +1 (binding) -Matthias On 7/21/21 1:18 PM, Patrick Stuedi

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

re sophie: The intent here was to include all blocked time (not just `RUNNING`). The caller can window the total blocked time themselves, and that can be compared with a timeseries of the state to understand the ratio in different states. I'll update the KIP to include `committed`. The admin API

[jira] [Created] (KAFKA-13125) Close KeyValueIterator implemented instance in internal tests (cont.)

Luke Chen created KAFKA-13125: - Summary: Close KeyValueIterator implemented instance in internal tests (cont.) Key: KAFKA-13125 URL: https://issues.apache.org/jira/browse/KAFKA-13125 Project: Kafka

[jira] [Created] (KAFKA-13124) Cl

Luke Chen created KAFKA-13124: - Summary: Cl Key: KAFKA-13124 URL: https://issues.apache.org/jira/browse/KAFKA-13124 Project: Kafka Issue Type: Sub-task Reporter: Luke Chen --

[DISCUSS] KIP-764 Configurable backlog size for creating Acceptor

Hi, Kafka. I proposed KIP-764, which tries to add new KafkaConfig to adjust Acceptor's backlog size. As described in the KIP and the ticket KAFKA-9648, currently backlog size is fixed value (50) and it may not be enough to handle incoming connections from massive clients. So we would like to

[jira] [Created] (KAFKA-13123) Close KeyValueIterator implemented instance in example codes and some tests

Luke Chen created KAFKA-13123: - Summary: Close KeyValueIterator implemented instance in example codes and some tests Key: KAFKA-13123 URL: https://issues.apache.org/jira/browse/KAFKA-13123 Project: Kafka

[jira] [Created] (KAFKA-13122) Close KeyValueIterator implemented instance to avoid resource leak

Luke Chen created KAFKA-13122: - Summary: Close KeyValueIterator implemented instance to avoid resource leak Key: KAFKA-13122 URL: https://issues.apache.org/jira/browse/KAFKA-13122 Project: Kafka