[jira] [Created] (KAFKA-13386) Foreign Key Join filtering valid records after a code change / schema evolved

Sergio Duran Vegas created KAFKA-13386: -- Summary: Foreign Key Join filtering valid records after a code change / schema evolved Key: KAFKA-13386 URL: https://issues.apache.org/jira/browse/KAFKA-13386

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #141

See Changes: [Jason Gustafson] KAFKA-13081: detect and handle doubly assigned partitions in cooperative assignor (#11068) -- [...truncated 3.18 MB...]

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

See Changes: -- [...truncated 494699 lines...] [2021-10-20T00:45:56.916Z] [2021-10-20T00:45:56.916Z] PlaintextConsumerTest > testFetchRecordLargerThanFetchMaxBytes()

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

Hi Mickael! Den tis 19 okt. 2021 kl 19:30 skrev Mickael Maison : > Hi Magnus, > > Thanks for the proposal. > > 1. Looking at the protocol section, isn't "ClientInstanceId" expected > to be a field in GetTelemetrySubscriptionsResponseV0? Otherwise, how > does a client retrieve this value? > Good

Re: [VOTE] Add TaskId field to StreamsException

+1 (binding) On 10/19/21 10:37 AM, Israel Ekpo wrote: Thanks for the KIP +1 from me (non binding) On Tue, Oct 19, 2021 at 12:39 PM Guozhang Wang wrote: Thanks for the KIP Sophie, I'm big +1 on this idea :) On Tue, Oct 19, 2021 at 6:48 AM Bill Bejeck wrote: Thanks for the KIP Sophie, I

Re: [VOTE] Add TaskId field to StreamsException

Thanks for the KIP +1 from me (non binding) On Tue, Oct 19, 2021 at 12:39 PM Guozhang Wang wrote: > Thanks for the KIP Sophie, I'm big +1 on this idea :) > > On Tue, Oct 19, 2021 at 6:48 AM Bill Bejeck wrote: > > > Thanks for the KIP Sophie, I think this will be helpful. > > > > +1(binding) >

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

Hi Magnus, Thanks for the proposal. 1. Looking at the protocol section, isn't "ClientInstanceId" expected to be a field in GetTelemetrySubscriptionsResponseV0? Otherwise, how does a client retrieve this value? 2. In the client API section, you mention a new method "clientInstanceId()". Can you

Re: [VOTE] Add TaskId field to StreamsException

Thanks for the KIP Sophie, I'm big +1 on this idea :) On Tue, Oct 19, 2021 at 6:48 AM Bill Bejeck wrote: > Thanks for the KIP Sophie, I think this will be helpful. > > +1(binding) > > -Bill > > On Mon, Oct 18, 2021 at 5:04 PM John Roesler wrote: > > > Thanks, Sophie, > > > > +1 from me. > > >

[jira] [Created] (KAFKA-13385) In the KRPC request header, translate null clientID to empty

Colin McCabe created KAFKA-13385: Summary: In the KRPC request header, translate null clientID to empty Key: KAFKA-13385 URL: https://issues.apache.org/jira/browse/KAFKA-13385 Project: Kafka

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

Den tis 19 okt. 2021 kl 13:22 skrev Tom Bentley : > Hi Magnus, > > I reviewed the KIP since you called the vote (sorry for not reviewing when > you announced your intention to call the vote). I have a few questions on > some of the details. > > 1. There's no Javadoc on

Re: KIP Process Needs Improvement

Hello, Knowles. I have some frustration with KIP process, also. Some features, that at glance requested by the community just can’t be done without explicit commiters approval. KIP-729 [1], KIP-686 [2], request the same feature, can be taken as a good example. Dear Kafka committers, what kind

Re: KIP Process Needs Improvement

Good morning Knowles, Thank you for sharing this feedback. I think your frustration is well founded. I think most/all of the active committers carry around a sense of guilt about KIPs that we haven’t been able to review. We do have a responsibility to hold auditable, public design discussions

KIP Process Needs Improvement

Good morning, The current process of KIPs needs to be improved. There are at least a handful of open KIPs with existing PRs that are in a purgatory state. I understand that people are busy, but if you are going to gatekeep Kafka with this process, then it must be responsive. Even if the community

Re: [VOTE] Add TaskId field to StreamsException

Thanks for the KIP Sophie, I think this will be helpful. +1(binding) -Bill On Mon, Oct 18, 2021 at 5:04 PM John Roesler wrote: > Thanks, Sophie, > > +1 from me. > > I was a little apprehensive about the potential to break > exception handler logic, but I agree with your comment in > the

[jira] [Created] (KAFKA-13384) FailedPartitionsCount metric is not updated if a partition log file was corrupted

Alexander created KAFKA-13384: - Summary: FailedPartitionsCount metric is not updated if a partition log file was corrupted Key: KAFKA-13384 URL: https://issues.apache.org/jira/browse/KAFKA-13384 Project:

[jira] [Resolved] (KAFKA-10540) Convert KStream aggregations to new PAPI

[ https://issues.apache.org/jira/browse/KAFKA-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-10540. -- Resolution: Fixed https://github.com/apache/kafka/pull/11315

[jira] [Resolved] (KAFKA-10539) Convert KStreamImpl joins to new PAPI

[ https://issues.apache.org/jira/browse/KAFKA-10539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-10539. -- Resolution: Fixed https://github.com/apache/kafka/pull/11356

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

Hi Magnus, I reviewed the KIP since you called the vote (sorry for not reviewing when you announced your intention to call the vote). I have a few questions on some of the details. 1. There's no Javadoc on ClientTelemetryPayload.data(), so I don't know whether the payload is exposed through this