[jira] [Created] (KAFKA-12639) AbstractCoordinator ignores backoff timeout when joining the consumer group

Matiss Gutmanis created KAFKA-12639: --- Summary: AbstractCoordinator ignores backoff timeout when joining the consumer group Key: KAFKA-12639 URL: https://issues.apache.org/jira/browse/KAFKA-12639 Pro

[jira] [Created] (KAFKA-12640) AbstractCoordinator ignores backoff timeout when joining the consumer group

Matiss Gutmanis created KAFKA-12640: --- Summary: AbstractCoordinator ignores backoff timeout when joining the consumer group Key: KAFKA-12640 URL: https://issues.apache.org/jira/browse/KAFKA-12640 Pro

[jira] [Created] (KAFKA-12641) Clear RemoteLogLeaderEpochState entry when it become empty.

Satish Duggana created KAFKA-12641: -- Summary: Clear RemoteLogLeaderEpochState entry when it become empty. Key: KAFKA-12641 URL: https://issues.apache.org/jira/browse/KAFKA-12641 Project: Kafka

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hi Sophie, That sounds great to take care of each case I can think of. Questions: 1. Do you mean the short-Circuit will also be implemented in KAFKA-12477? 2. I don't think KAFKA-12638 is the blocker of this KIP-726, Am I right? 3. So, does that mean we still have possibility to have multiple consu

Re: [VOTE] 2.7.1 RC2

Hi, Here is a successful build of 2.7.1 RC2: https://ci-builds.apache.org/job/Kafka/job/kafka-2.7-jdk8/144/ Thanks On Thu, Apr 8, 2021 at 6:27 PM Mickael Maison wrote: > > Hello Kafka users, developers and client-developers, > > This is the third candidate for release of Apache Kafka 2.7.1. > >

[jira] [Created] (KAFKA-12642) Improve Rebalance reason upon metadata change

Nicolas Guyomar created KAFKA-12642: --- Summary: Improve Rebalance reason upon metadata change Key: KAFKA-12642 URL: https://issues.apache.org/jira/browse/KAFKA-12642 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-12643) Kafka Streams 2.7 with Kafka Broker 2.6.x regression: bad timestamp in transform/process (this.context.schedule function)

David EVANO created KAFKA-12643: --- Summary: Kafka Streams 2.7 with Kafka Broker 2.6.x regression: bad timestamp in transform/process (this.context.schedule function) Key: KAFKA-12643 URL: https://issues.apache.org/ji

[jira] [Resolved] (KAFKA-12591) Remove deprecated `quota.producer.default` and `quota.consumer.default` configurations

[ https://issues.apache.org/jira/browse/KAFKA-12591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12591. - Fix Version/s: 3.0.0 Reviewer: Rajini Sivaram Resolution: Fixed > Remove depreca

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

See

[jira] [Created] (KAFKA-12644) Add Missing Class-Level Javadoc to Decendants of org.apache.kafka.common.errors.ApiException

Israel Ekpo created KAFKA-12644: --- Summary: Add Missing Class-Level Javadoc to Decendants of org.apache.kafka.common.errors.ApiException Key: KAFKA-12644 URL: https://issues.apache.org/jira/browse/KAFKA-12644

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

Hey y'all, I'd like to draw you attention to a new KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-731%3A+Record+Rate+Limiting+for+Kafka+Connect Lemme know what you think. Thanks! Ryanne

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

1) Yes, all of the above will be part of KAFKA-12477 (not KIP-726) 2) No, KAFKA-12638 would be nice to have but I don't think it's appropriate to remove the default implementation of #onPartitionsLost in 3.0 since we never gave any indication yet that we intend to remove it 3) Yes, this would be

[jira] [Created] (KAFKA-12645) KIP-731: Record Rate Limiting for Kafka Connect

Ryanne Dolan created KAFKA-12645: Summary: KIP-731: Record Rate Limiting for Kafka Connect Key: KAFKA-12645 URL: https://issues.apache.org/jira/browse/KAFKA-12645 Project: Kafka Issue Type: I

[jira] [Resolved] (KAFKA-12449) Remove deprecated WindowStore#put

[ https://issues.apache.org/jira/browse/KAFKA-12449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12449. - Fix Version/s: 3.0.0 Resolution: Fixed > Remove deprecated WindowStore#put >

[GitHub] [kafka-site] mjsax merged pull request #338: MINOR quickstart.html remove extra closing paren, fix syntax

mjsax merged pull request #338: URL: https://github.com/apache/kafka-site/pull/338 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [kafka-site] mjsax commented on pull request #338: MINOR quickstart.html remove extra closing paren, fix syntax

mjsax commented on pull request #338: URL: https://github.com/apache/kafka-site/pull/338#issuecomment-816903340 Thanks @Alee4738! Merged both PRs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

Re: [DISCUSS] KIP-718: Make KTable Join on Foreign key unopinionated

Hi everyone, I am fine with sticking with Materialized and adding the info to the javadoc then - so we keep the footprint smaller. I will then update the KIP to match what we discussed here and send it for a vote next week. I will raise a new bug-fix ticket and change KAFKA-10383

Re: Subject: [VOTE] 2.8.0 RC1

Hi John, Thanks for running the 2.8.0 release! I've started to validate it and noticed the site-docs haven't been installed to https://kafka.apache.org/28/documentation.html yet. Thanks again! -Bill On Tue, Apr 6, 2021 at 5:37 PM John Roesler wrote: > Hello Kafka users, developers and client

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

See

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

See Changes: -- [...truncated 3399 lines...] [2021-04-09T20:58:41.594Z] * Try: [2021-04-09T20:58:41.594Z] Run with --stacktrace option to get the stack trace. Run with --inf

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

See

[jira] [Created] (KAFKA-12647) Implement loading snapshot in the broker

Jose Armando Garcia Sancio created KAFKA-12647: -- Summary: Implement loading snapshot in the broker Key: KAFKA-12647 URL: https://issues.apache.org/jira/browse/KAFKA-12647 Project: Kafka

[jira] [Created] (KAFKA-12646) Implement loading snapshot in the controller

Jose Armando Garcia Sancio created KAFKA-12646: -- Summary: Implement loading snapshot in the controller Key: KAFKA-12646 URL: https://issues.apache.org/jira/browse/KAFKA-12646 Project: Kafk

[jira] [Created] (KAFKA-12648) Experiment with resilient isomorphic topologies

A. Sophie Blee-Goldman created KAFKA-12648: -- Summary: Experiment with resilient isomorphic topologies Key: KAFKA-12648 URL: https://issues.apache.org/jira/browse/KAFKA-12648 Project: Kafka

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

See

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

See Changes: -- [...truncated 474870 lines...] [2021-04-10T00:21:54.316Z] [2021-04-10T00:21:54.316Z] MetricsTest > testSessionExpireListenerMetrics() PASSED [2021-04-10T00:

[jira] [Created] (KAFKA-12649) Expose cache resizer for dynamic memory allocation

A. Sophie Blee-Goldman created KAFKA-12649: -- Summary: Expose cache resizer for dynamic memory allocation Key: KAFKA-12649 URL: https://issues.apache.org/jira/browse/KAFKA-12649 Project: Kafka

[jira] [Created] (KAFKA-12650) NPE in InternalTopicManager#cleanUpCreatedTopics

A. Sophie Blee-Goldman created KAFKA-12650: -- Summary: NPE in InternalTopicManager#cleanUpCreatedTopics Key: KAFKA-12650 URL: https://issues.apache.org/jira/browse/KAFKA-12650 Project: Kafka

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

See