Limit number of topic partitions

Hi. I'd like your thoughts on https://issues.apache.org/jira/browse/KAFKA-9590?jql=text%20~%20%22limit%20topic%20partitions%22 (tldr: its about limiting number of topic partitions via a read-only configuration). I am going to start writing a KIP for this soon, and will share on this thread as I

Build failed in Jenkins: kafka-2.5-jdk8 #58

See Changes: [wangguoz] KAFKA-9668: Iterating over KafkaStreams.getAllMetadata() results in -- [...truncated 5.86 MB...]

Build failed in Jenkins: kafka-trunk-jdk11 #1218

See Changes: [github] MINOR: Check store directory empty to decide whether throw task -- [...truncated 2.92 MB...]

[jira] [Resolved] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-5722. - Resolution: Duplicate > Refactor ConfigCommand to use the AdminClient >

[jira] [Created] (KAFKA-9679) Mock consumer should behave consistent with actual consumer

Boyang Chen created KAFKA-9679: -- Summary: Mock consumer should behave consistent with actual consumer Key: KAFKA-9679 URL: https://issues.apache.org/jira/browse/KAFKA-9679 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9662) Throttling system test fails when messages are produced before consumer starts up

[ https://issues.apache.org/jira/browse/KAFKA-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-9662. - Resolution: Fixed > Throttling system test fails when messages are produced before consumer >

[jira] [Created] (KAFKA-9678) Introduce bounded exponential backoff in clients

Guozhang Wang created KAFKA-9678: Summary: Introduce bounded exponential backoff in clients Key: KAFKA-9678 URL: https://issues.apache.org/jira/browse/KAFKA-9678 Project: Kafka Issue Type:

Build failed in Jenkins: kafka-trunk-jdk11 #1217

See Changes: [github] KAFKA-9668: Iterating over KafkaStreams.getAllMetadata() results in -- [...truncated 5.88 MB...]

[jira] [Created] (KAFKA-9677) Low consume bandwidth quota may cause consumer not being able to fetch data

Anna Povzner created KAFKA-9677: --- Summary: Low consume bandwidth quota may cause consumer not being able to fetch data Key: KAFKA-9677 URL: https://issues.apache.org/jira/browse/KAFKA-9677 Project:

Re: [VOTE] KIP-557: Add emit on change support for Kafka Streams

Hi all, I have decided to pass this KIP with 2 binding votes and 3 non-binding votes (including mine). I will update KIP status shortly after this. Best, Richard On Thu, Mar 5, 2020 at 3:45 PM Richard Yu wrote: > Hi all, > > Just polling for some last changes on the name. > I think that since

Build failed in Jenkins: kafka-trunk-jdk8 #4299

See Changes: [github] KAFKA-9668: Iterating over KafkaStreams.getAllMetadata() results in [github] MINOR: Check store directory empty to decide whether throw task --

Build failed in Jenkins: kafka-2.5-jdk8 #57

See Changes: [mumrah] KAFKA-9662: Wait for consumer offset reset in throttle test to avoid -- [...truncated 2.89 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Build failed in Jenkins: kafka-trunk-jdk11 #1216

See Changes: [github] KAFKA-9662: Wait for consumer offset reset in throttle test to avoid -- [...truncated 2.90 MB...] org.apache.kafka.streams.test.TestRecordTest >

Jenkins build is back to normal : kafka-trunk-jdk11 #1215

See

[jira] [Created] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

Boyang Chen created KAFKA-9676: -- Summary: Add test coverage for new ActiveTaskCreator and StandbyTaskCreator Key: KAFKA-9676 URL: https://issues.apache.org/jira/browse/KAFKA-9676 Project: Kafka

[jira] [Created] (KAFKA-9675) RocksDB metrics reported always at zero

Michael Viamari created KAFKA-9675: -- Summary: RocksDB metrics reported always at zero Key: KAFKA-9675 URL: https://issues.apache.org/jira/browse/KAFKA-9675 Project: Kafka Issue Type:

Re: Create content permission

Added best, Colin On Fri, Mar 6, 2020, at 09:45, Cheng Tan wrote: > It’s d8tltanc. Thank you, > > > On Mar 6, 2020, at 9:35 AM, Matthias J. Sax wrote: > > > > -BEGIN PGP SIGNED MESSAGE- > > Hash: SHA512 > > > > What is your wiki account id? > > > > - -Matthias > > > > On 3/5/20

[jira] [Resolved] (KAFKA-9635) Should ConfigProvider.subscribe be deprecated?

[ https://issues.apache.org/jira/browse/KAFKA-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-9635. - Resolution: Duplicate Let's continue the discussion on the mailing list. > Should

Re: Create content permission

It’s d8tltanc. Thank you, > On Mar 6, 2020, at 9:35 AM, Matthias J. Sax wrote: > > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > What is your wiki account id? > > - -Matthias > > On 3/5/20 2:15 PM, Cheng Tan wrote: >> Hello, >> >> My name is Cheng Tan and I’m working at Confluent.

[jira] [Created] (KAFKA-9674) Task corruption should also close the producer if necessary

Boyang Chen created KAFKA-9674: -- Summary: Task corruption should also close the producer if necessary Key: KAFKA-9674 URL: https://issues.apache.org/jira/browse/KAFKA-9674 Project: Kafka Issue

[jira] [Created] (KAFKA-9673) Conditionally apply SMTs

Tom Bentley created KAFKA-9673: -- Summary: Conditionally apply SMTs Key: KAFKA-9673 URL: https://issues.apache.org/jira/browse/KAFKA-9673 Project: Kafka Issue Type: New Feature

Re: Create content permission

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 What is your wiki account id? - -Matthias On 3/5/20 2:15 PM, Cheng Tan wrote: > Hello, > > My name is Cheng Tan and I’m working at Confluent. Can I get the > create content permission so I can create a KIP? Thank you. > > Best, - Cheng Tan >

Re: Subject: [VOTE] 2.4.1 RC0

+1 (binding) Checked the git hash and branch, looked at the docs a bit. Ran quickstart (although not the connect or streams parts). Looks good. best, Colin On Fri, Mar 6, 2020, at 07:31, David Arthur wrote: > +1 (binding) > > Download kafka_2.13-2.4.1 and verified signature, ran

Re: Subject: [VOTE] 2.4.1 RC0

+1 (binding) Download kafka_2.13-2.4.1 and verified signature, ran quickstart, everything looks good. Thanks for running this release, Bill! -David On Wed, Mar 4, 2020 at 6:06 AM Eno Thereska wrote: > Hi Bill, > > I built from source and ran unit and integration tests. They passed. > There

Re: [VOTE] KIP-570: Add leader epoch in StopReplicaRequest

Hi all, The vote has passed with +3 binding votes (Jason Gustafson, Gwen Shapira, Jun Rao). Thanks to everyone! Best, David On Wed, Mar 4, 2020 at 9:02 AM David Jacot wrote: > Hi Jun, > > You're right. I have noticed it while implementing it. I plan to use a > default > value as a sentinel

[jira] [Created] (KAFKA-9672) Dead broker in ISR cause isr-expiration to fail with exception

Ivan Yurchenko created KAFKA-9672: - Summary: Dead broker in ISR cause isr-expiration to fail with exception Key: KAFKA-9672 URL: https://issues.apache.org/jira/browse/KAFKA-9672 Project: Kafka

Re: [VOTE] KIP-518: Allow listing consumer groups per state

Thanks David and Gwen for the votes Colin, I believe I've answered all your questions, can you take another look? So far we have 1 binding and 5 non binding votes. On Mon, Mar 2, 2020 at 4:56 PM Gwen Shapira wrote: > > +1 (binding) > > Gwen Shapira > Engineering Manager | Confluent >

Re: [VOTE] KIP-409: Allow creating under-replicated topics and partitions

Bumping this thread once again. So far we only have 4 non binding votes. Please take a look at the KIP, share any feedback and consider voting. Thanks On Thu, Feb 27, 2020 at 12:03 AM Ryanne Dolan wrote: > > Hey all, please consider voting for this KIP. It's really a shame that > topic

[jira] [Created] (KAFKA-9671) Support sha512sum file format

Aljoscha Pörtner created KAFKA-9671: --- Summary: Support sha512sum file format Key: KAFKA-9671 URL: https://issues.apache.org/jira/browse/KAFKA-9671 Project: Kafka Issue Type: Improvement