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

See

[jira] [Resolved] (KAFKA-6655) CleanupThread: Failed to lock the state directory due to an unexpected exception (Windows OS)

[ https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-6655. --- Resolution: Fixed This should be fixed, a number of improvements were made

[jira] [Created] (KAFKA-12729) controller leader keep disconnected and block the cluster

luws created KAFKA-12729: Summary: controller leader keep disconnected and block the cluster Key: KAFKA-12729 URL: https://issues.apache.org/jira/browse/KAFKA-12729 Project: Kafka Issue Type: Bug

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

See

[VOTE] KIP-731: Record Rate Limiting for Kafka Connect

Hey y'all, I'd like to start the vote on KIP-731, which enables operators to limit Connector throughput. https://cwiki.apache.org/confluence/display/KAFKA/KIP-731%3A+Record+Rate+Limiting+for+Kafka+Connect Thanks for your votes! Ryanne

Re: [VOTE] KIP-735: Increase default consumer session timeout

Thanks for the KIP Jason, +1(binding) -Bill On Wed, Apr 28, 2021 at 7:47 PM Guozhang Wang wrote: > +1. Thanks Jason！ > > On Wed, Apr 28, 2021 at 12:50 PM Gwen Shapira > wrote: > > > I love this improvement. > > > > +1 (binding) > > > > On Wed, Apr 28, 2021 at 10:46 AM Jason Gustafson > > > >

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

See

Re: [VOTE] KIP-735: Increase default consumer session timeout

+1. Thanks Jason！ On Wed, Apr 28, 2021 at 12:50 PM Gwen Shapira wrote: > I love this improvement. > > +1 (binding) > > On Wed, Apr 28, 2021 at 10:46 AM Jason Gustafson > > wrote: > > > Hi All, > > > > I'd like to start a vote on KIP-735: > > > > >

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

See

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

Excellent Sophie. I have the initial changes (without the Unit tests yet) here https://github.com/izzyacademy/kafka/commit/c7094fae666f407e413c2b9d40e980a68aebf81f Please let me know what you think. I will be working on the Unit tests in about a day and will submit a PR once the Unit tests are

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

Oh, yeah, looks like a copy/paste error. I'll admit I didn't type out each of these method signatures by hand from scratch. Thanks for catching this! Added you so you should be able to edit the KIP now and fix this up. On Wed, Apr 28, 2021 at 1:29 PM Israel Ekpo wrote: > I was not able to

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

I was not able to edit the wiki page for the KIP. When you have a moment, please could you grant me permissions? https://cwiki.apache.org/confluence/display/~iekpo On Wed, Apr 28, 2021 at 4:17 PM Israel Ekpo wrote: > > Hi Everyone, > > I noticed that the method signature in the KIP had the

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

Hi Everyone, I noticed that the method signature in the KIP had the incorrect return value. https://cwiki.apache.org/confluence/display/KAFKA/KIP-633:+Drop+24+hour+default+of+grace+period+in+Streams Should I go ahead and update this in the KIP? I just noticed the error during my implementation

Re: [VOTE] KIP-735: Increase default consumer session timeout

I love this improvement. +1 (binding) On Wed, Apr 28, 2021 at 10:46 AM Jason Gustafson wrote: > Hi All, > > I'd like to start a vote on KIP-735: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-735%3A+Increase+default+consumer+session+timeout > . > +1 > from myself obviously > >

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

See

Re: [VOTE] KIP-735: Increase default consumer session timeout

Thanks for the KIP, +1 (binding) -Sophie On Wed, Apr 28, 2021 at 10:46 AM Jason Gustafson wrote: > Hi All, > > I'd like to start a vote on KIP-735: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-735%3A+Increase+default+consumer+session+timeout > . > +1 > from myself obviously > >

[jira] [Created] (KAFKA-12728) Update Gradle version: 6.8 -->> 7.0

Dejan Stojadinović created KAFKA-12728: -- Summary: Update Gradle version: 6.8 -->> 7.0 Key: KAFKA-12728 URL: https://issues.apache.org/jira/browse/KAFKA-12728 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-9295) KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-9295: --- Still failing, saw this on both the Java 8 and Java 11 build of a PR:

[jira] [Created] (KAFKA-12727) Flaky test ListConsumerGroupTest.testListConsumerGroupsWithStates

A. Sophie Blee-Goldman created KAFKA-12727: -- Summary: Flaky test ListConsumerGroupTest.testListConsumerGroupsWithStates Key: KAFKA-12727 URL: https://issues.apache.org/jira/browse/KAFKA-12727

[jira] [Resolved] (KAFKA-12417) streams module should use `testRuntimeClasspath` instead of `testRuntime` configuration

[ https://issues.apache.org/jira/browse/KAFKA-12417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dejan Stojadinović resolved KAFKA-12417. Resolution: Done Resolving as done (commit is merged into trunk). > streams

[VOTE] KIP-735: Increase default consumer session timeout

Hi All, I'd like to start a vote on KIP-735: https://cwiki.apache.org/confluence/display/KAFKA/KIP-735%3A+Increase+default+consumer+session+timeout. +1 from myself obviously -Jason

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

See Changes: -- [...truncated 472855 lines...] [2021-04-28T16:54:06.669Z] [2021-04-28T16:54:06.669Z] ControllerIntegrationTest >

[jira] [Created] (KAFKA-12726) misbehaving Task.stop() can prevent other Tasks from stopping

Ryanne Dolan created KAFKA-12726: Summary: misbehaving Task.stop() can prevent other Tasks from stopping Key: KAFKA-12726 URL: https://issues.apache.org/jira/browse/KAFKA-12726 Project: Kafka

[jira] [Created] (KAFKA-12725) Add transaction start offset to WriteTxnMarker API

Jason Gustafson created KAFKA-12725: --- Summary: Add transaction start offset to WriteTxnMarker API Key: KAFKA-12725 URL: https://issues.apache.org/jira/browse/KAFKA-12725 Project: Kafka

[jira] [Resolved] (KAFKA-12716) Admin API for aborting transactions

[ https://issues.apache.org/jira/browse/KAFKA-12716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12716. - Resolution: Fixed > Admin API for aborting transactions >

Re: [DISCUSS] KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp

Hi David and Jason, Thank you for looking over the KIP. I've added extra text regarding motivation and included the bump in API version required for the earlier versions issue. Regarding returning the timestamp type, I was trying to keep the KIP small and consistent with the existing

[jira] [Created] (KAFKA-12724) Add 2.8.0 to system tests and streams upgrade tests

Kamal Chandraprakash created KAFKA-12724: Summary: Add 2.8.0 to system tests and streams upgrade tests Key: KAFKA-12724 URL: https://issues.apache.org/jira/browse/KAFKA-12724 Project: Kafka

[jira] [Created] (KAFKA-12723) Potential NPE in SnapshottableHashTable.java

loyi created KAFKA-12723: Summary: Potential NPE in SnapshottableHashTable.java Key: KAFKA-12723 URL: https://issues.apache.org/jira/browse/KAFKA-12723 Project: Kafka Issue Type: Bug Affects