Re: [DISCUSS] KIP-921 OpenJDK CRaC support

Hi all, I haven't seen much reactions on this proposal. Is there any general policy regarding dependencies, or a prior decision that would hint on this? Thanks! Radim On 21. 04. 23 10:10, Radim Vansa wrote: Caution: This email originated from outside of the organization. Do not click links

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.4 #117

See

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

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #172

See Changes: -- [...truncated 339122 lines...] [2023-04-26T05:13:55.302Z] [2023-04-26T05:13:55.302Z] org.apache.kafka.streams.integration.SuppressionIntegrationTest > shoul

Re: [DISCUSS] Re-visit end of life policy

Adding the user-mailing list. Seems relevant to everybody. On 4/20/23 2:45 AM, Divij Vaidya wrote: Thank you Matthias for your comments. I agree with you that the decision should be driven based on strong community ask as it introduces a significant overhead on the maintainers. I was hoping tha

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

See

[jira] [Resolved] (KAFKA-14848) KafkaConsumer incorrectly passes locally-scoped deserializers to FetchConfig

[ https://issues.apache.org/jira/browse/KAFKA-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-14848. --- Resolution: Fixed > KafkaConsumer incorrectly passes locally-scoped deserializers to FetchConfig > -

Re: Test failures

HI Ismail, There is a PR to fix the failure in https://github.com/apache/kafka/pull/13634 On Tue, Apr 25, 2023 at 9:40 PM Ismael Juma wrote: > I was looking at the CI builds and I came across the following test failure > that seems to be clear and consistent: > > org.mockito.exceptions.verifica

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

See

[jira] [Created] (KAFKA-14937) Refactoring for client code to reduce boilerplate

Kirk True created KAFKA-14937: - Summary: Refactoring for client code to reduce boilerplate Key: KAFKA-14937 URL: https://issues.apache.org/jira/browse/KAFKA-14937 Project: Kafka Issue Type: Sub-t

Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client

Thanks for the vote. We've decided to make a minor change to the default timeout from 5min to 2min. On Tue, Apr 25, 2023 at 11:42 AM David Jacot wrote: > +1 (binding) Thanks for the KIP, Philip! > > Le mar. 25 avr. 2023 à 20:23, José Armando García Sancio > a écrit : > > > +1. Thanks for the d

Re: Test failures

I was looking at the CI builds and I came across the following test failure that seems to be clear and consistent: org.mockito.exceptions.verification.TooFewActualInvocations: kafkaBasedLog.send(, , ); Wanted 2 times: -> at org.apache.kafka.connect.util.KafkaBasedLog.send(KafkaBasedLog.java:376) B

[DISCUSS] KIP-923: Add A Grace Period to Stream Table Join

Hello everybody, I have a stream proposal to improve the stream table join by adding a grace period and buffer to the stream side of the join to allow processing in timestamp order matching the recent improvements of the versioned tables. Please take a look here

[jira] [Created] (KAFKA-14936) Add Grace Period To Stream Table Join

Walker Carlson created KAFKA-14936: -- Summary: Add Grace Period To Stream Table Join Key: KAFKA-14936 URL: https://issues.apache.org/jira/browse/KAFKA-14936 Project: Kafka Issue Type: Improve

Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client

+1 (binding) Thanks for the KIP, Philip! Le mar. 25 avr. 2023 à 20:23, José Armando García Sancio a écrit : > +1. Thanks for the design. Looking forward to the implementation. > > On Tue, Apr 25, 2023 at 10:49 AM Jason Gustafson > wrote: > > > > +1 Thanks Philip! > > > > > > On Thu, Apr 13, 202

Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client

+1. Thanks for the design. Looking forward to the implementation. On Tue, Apr 25, 2023 at 10:49 AM Jason Gustafson wrote: > > +1 Thanks Philip! > > > On Thu, Apr 13, 2023 at 7:49 AM Kirk True wrote: > > > +1 (non-binding) > > > > > On Apr 10, 2023, at 1:53 PM, Philip Nee wrote: > > > > > > Hey

Re: [VOTE] KIP-909: DNS Resolution Fallures Should Not Fail the Client

+1 Thanks Philip! On Thu, Apr 13, 2023 at 7:49 AM Kirk True wrote: > +1 (non-binding) > > > On Apr 10, 2023, at 1:53 PM, Philip Nee wrote: > > > > Hey everyone! > > > > I'm starting a vote for KIP-909: DNS Resolution Fallures Should Not Fail > > the Client

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #171

See Changes: -- [...truncated 501382 lines...] [2023-04-25T17:37:43.746Z] > Task :connect:json:jar UP-TO-DATE [2023-04-25T17:37:43.746Z] > Task :connect:json:generateMetadata

[jira] [Created] (KAFKA-14935) Wire Protocol Documentation Does Not Explain Header Versioning

Andrew Thaddeus Martin created KAFKA-14935: -- Summary: Wire Protocol Documentation Does Not Explain Header Versioning Key: KAFKA-14935 URL: https://issues.apache.org/jira/browse/KAFKA-14935 Pr

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

See

[jira] [Resolved] (KAFKA-14931) Revert KAFKA-14561 in 3.5

[ https://issues.apache.org/jira/browse/KAFKA-14931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan resolved KAFKA-14931. Resolution: Fixed > Revert KAFKA-14561 in 3.5 > - > >

Consumer Lag Metrics/ Topic level metrics

Dear Kafka Experts Could you please suggest good metrics exporter for consumer lag and topic level metrics apart from Linkedin kafka burrow for the kafka broker cluster.

[jira] [Created] (KAFKA-14934) KafkaClusterTestKit makes FaultHandler accessible

David Arthur created KAFKA-14934: Summary: KafkaClusterTestKit makes FaultHandler accessible Key: KAFKA-14934 URL: https://issues.apache.org/jira/browse/KAFKA-14934 Project: Kafka Issue Type:

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

See Changes: -- [...truncated 471516 lines...] [2023-04-25T13:35:30.005Z] [2023-04-25T13:35:30.005Z] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 >

Re: [DISCUSS] KIP-872: Add Serializer#serializeToByteBuffer() to reduce memory copying

4. I did not observe any changes made to the KIP about this. Could we please add a JavaDoc to serializeToByteBuffer() where we clearly call out that the indices of input ByteBuffer will be modified. 5. Thank you. My comment on this is resolved now. 6. We should probably mention the strategy to re

[jira] [Resolved] (KAFKA-14172) bug: State stores lose state when tasks are reassigned under EOS wit…

[ https://issues.apache.org/jira/browse/KAFKA-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Brutschy resolved KAFKA-14172. Resolution: Fixed > bug: State stores lose state when tasks are reassigned under EOS wit…

Re: KIP-919: Allow AdminClient to Talk Directly with the KRaft Controller Quorum

Thank you for the KIP Colin. In general, I like the idea of having the ability to interact directly with the controllers. I agree with your observation that it helps in situations where you would want to get data directly from the controller instead of going via a broker. I have some general comme

[jira] [Resolved] (KAFKA-14869) txn and group coordinator downgrade foundation

[ https://issues.apache.org/jira/browse/KAFKA-14869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14869. - Fix Version/s: 3.2.4 3.1.3 3.0.3 3.4.1

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #147

See Changes: -- [...truncated 369176 lines...] [2023-04-25T10:57:28.077Z] DescribeQuorumRequestTest > testDescribeQuorumNotSupportedByZkBrokers() > kafka.server.DescribeQuor

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.0 #221

See Changes: -- [...truncated 355564 lines...] [2023-04-25T10:46:49.919Z] [2023-04-25T10:46:49.919Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest

[jira] [Created] (KAFKA-14933) Document Kafka Connect's log level REST APIs added in KIP-495

Yash Mayya created KAFKA-14933: -- Summary: Document Kafka Connect's log level REST APIs added in KIP-495 Key: KAFKA-14933 URL: https://issues.apache.org/jira/browse/KAFKA-14933 Project: Kafka Is