Build failed in Jenkins: kafka-trunk-jdk14 #156

See Changes: -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building remotely on H23 (ubuntu) in workspace

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

See Changes: [github] MINOR: Improve JavaDocs in Kafka Streams (#8772) [matthias] KAFKA-10030: Allow fetching a key from a single partition (#8706) -- [...truncated 1.56

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

See Changes: [github] Bump trunk to 2.7.0-SNAPSHOT (#8746) -- [...truncated 1.74 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Build failed in Jenkins: kafka-2.6-jdk8 #8

See Changes: [rajinisivaram] KAFKA-9392; Clarify deleteAcls javadoc and add test for create/delete -- [...truncated 4.93 MB...] kafka.admin.DescribeConsumerGroupTest >

[jira] [Created] (KAFKA-10081) Execution failed for task ':clients:spotbugsMain' in recent build

Luke Chen created KAFKA-10081: - Summary: Execution failed for task ':clients:spotbugsMain' in recent build Key: KAFKA-10081 URL: https://issues.apache.org/jira/browse/KAFKA-10081 Project: Kafka

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

See Changes: [github] KAFKA-10030: Allow fetching a key from a single partition (#8706) [github] Bump trunk to 2.7.0-SNAPSHOT (#8746) -- [...truncated 1.74 MB...]

Build failed in Jenkins: kafka-2.4-jdk8 #217

See Changes: [wangguoz] KAFKA-9987: optimize sticky assignment algorithm for same-subscription -- [...truncated 1.42 MB...]

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

See Changes: [github] MINOR: Code cleanup and assertion message fixes in Connect integration [github] MINOR: Remove no longer used ReflectionsUtil class (#8762) [github] Kafka-10064 Add documentation for

Build failed in Jenkins: kafka-trunk-jdk14 #155

See Changes: [github] Bump trunk to 2.7.0-SNAPSHOT (#8746) -- Started by an SCM change Running as SYSTEM [EnvInject] - Loading node environment variables. Building

[jira] [Created] (KAFKA-10080) IllegalStateException after duplicate CompleteCommit append to transaction log

Jason Gustafson created KAFKA-10080: --- Summary: IllegalStateException after duplicate CompleteCommit append to transaction log Key: KAFKA-10080 URL: https://issues.apache.org/jira/browse/KAFKA-10080

Build failed in Jenkins: kafka-trunk-jdk14 #154

See Changes: [github] MINOR: Code cleanup and assertion message fixes in Connect integration [github] MINOR: Remove no longer used ReflectionsUtil class (#8762) [github] Kafka-10064 Add documentation for

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

See Changes: [github] MINOR: Code cleanup and assertion message fixes in Connect integration [github] MINOR: Remove no longer used ReflectionsUtil class (#8762) [github] Kafka-10064 Add documentation for

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

See Changes: [wangguoz] KAFKA-9987: optimize sticky assignment algorithm for same-subscription -- [...truncated 1.56 MB...]

[jira] [Resolved] (KAFKA-10030) Throw exception while fetching a key from a single partition

[ https://issues.apache.org/jira/browse/KAFKA-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10030. - Resolution: Fixed > Throw exception while fetching a key from a single partition >

Build failed in Jenkins: kafka-trunk-jdk14 #153

See Changes: [github] KAFKA-9987: optimize sticky assignment algorithm for same-subscription -- [...truncated 1.74 MB...]

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

See Changes: [github] KAFKA-9987: optimize sticky assignment algorithm for same-subscription -- [...truncated 1.74 MB...]

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

See Changes: [github] KAFKA-9987: optimize sticky assignment algorithm for same-subscription -- [...truncated 1.74 MB...]

[jira] [Resolved] (KAFKA-10064) Add documentation for KIP-571

[ https://issues.apache.org/jira/browse/KAFKA-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10064. - Resolution: Fixed > Add documentation for KIP-571 > - > >

Jenkins build is back to normal : kafka-2.0-jdk8 #319

See

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

See

Build failed in Jenkins: kafka-2.2-jdk8 #47

See Changes: [vvcephei] MINOR: Fix Streams EOS system tests by adding clean-up of state dir -- [...truncated 2.53 MB...] kafka.utils.CommandLineUtilsTest >

Build failed in Jenkins: kafka-1.1-jdk8 #291

See Changes: [vvcephei] MINOR: Fix Streams EOS system tests by adding clean-up of state dir [vvcephei] KAFKA-8417: Remove redundant network definition --net=host when starting [vvcephei] KAFKA-8499: ensure java

Jenkins build is back to normal : kafka-2.3-jdk8 #210

See

[jira] [Created] (KAFKA-10079) Support high availability for in-memory stores

Sophie Blee-Goldman created KAFKA-10079: --- Summary: Support high availability for in-memory stores Key: KAFKA-10079 URL: https://issues.apache.org/jira/browse/KAFKA-10079 Project: Kafka

Build failed in Jenkins: kafka-2.1-jdk8 #267

See Changes: [vvcephei] MINOR: Fix Streams EOS system tests by adding clean-up of state dir [vvcephei] KAFKA-8499: ensure java is in PATH for ducker system tests (#6898)

[jira] [Resolved] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9821. Resolution: Fixed > Stream task may skip assignment with static members and

[jira] [Created] (KAFKA-10078) Partition may skip assignment with static members and incremental rebalances

Sophie Blee-Goldman created KAFKA-10078: --- Summary: Partition may skip assignment with static members and incremental rebalances Key: KAFKA-10078 URL: https://issues.apache.org/jira/browse/KAFKA-10078

Jenkins build is back to normal : kafka-2.6-jdk8 #7

See

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

See Changes: [github] KAFKA-10074: Improve performance of `matchingAcls` (#8769) -- [...truncated 5.94 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Resolved] (KAFKA-10011) lockedTaskDirectories should be cleared when task gets closed dirty in HandleLostAll

[ https://issues.apache.org/jira/browse/KAFKA-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10011. - Resolution: Fixed > lockedTaskDirectories should be cleared when task gets closed dirty in >

[jira] [Resolved] (KAFKA-10010) Should make state store registration idempotent

[ https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10010. - Resolution: Fixed > Should make state store registration idempotent >

[jira] [Created] (KAFKA-10077) Filter downstream of state-store results in suprious tombstones

Andy Coates created KAFKA-10077: --- Summary: Filter downstream of state-store results in suprious tombstones Key: KAFKA-10077 URL: https://issues.apache.org/jira/browse/KAFKA-10077 Project: Kafka

[jira] [Resolved] (KAFKA-9392) Document and add test for deleteAcls that match single/multiple resources

[ https://issues.apache.org/jira/browse/KAFKA-9392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9392. --- Reviewer: Manikumar Resolution: Fixed > Document and add test for deleteAcls that

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hi John, Just to add to my previous email(and sorry for the spam), if we consider using Bytes/byte[] and manually invoke the serdes, if you could provide examples where the same Serde for keys won't work for the prefix types. As far as my understanding goes, the prefix seek would depend upon

[jira] [Created] (KAFKA-10076) Doc prefixed vs. non-prefix configs

Ron Dagostino created KAFKA-10076: - Summary: Doc prefixed vs. non-prefix configs Key: KAFKA-10076 URL: https://issues.apache.org/jira/browse/KAFKA-10076 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-10074) Improve performance of `matchingAcls`

[ https://issues.apache.org/jira/browse/KAFKA-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-10074. - Reviewer: Rajini Sivaram Resolution: Fixed > Improve performance of `matchingAcls` >

[jira] [Created] (KAFKA-10075) Kafka client stucks after Kafka-cluster unavailability

Dmitry Mischenko created KAFKA-10075: Summary: Kafka client stucks after Kafka-cluster unavailability Key: KAFKA-10075 URL: https://issues.apache.org/jira/browse/KAFKA-10075 Project: Kafka

Re: [VOTE] KIP-578: Add configuration to limit number of partitions

Thanks Colin. Have updated the KIP per your recommendations. Let me know what you think. Thanks Harsha for the vote. On Wed, May 27, 2020 at 8:17 PM Colin McCabe wrote: > Hi Gokul Ramanan Subramanian, > > Thanks for the KIP. > > Can you please modify the KIP to remove the reference to the

Re: [DISCUSS] Apache Kafka 2.6.0 release

Thanks Randall Hauch! On Sat, May 30, 2020 at 12:52 PM Randall Hauch wrote: > Hi, Kowshik, > > Thanks for the update on KIP-584. This is listed on the "Postponed" section > of the AK 2.6.0 release plan ( > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=152113430 > ). > > Best

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

See Changes: [github] MINOR: Align the constructor of KafkaConsumer to KafkaProducer (#8605) [github] MINOR: Update zstd to 1.4.5 (#8766) [github] KAFKA-10060 GroupMetadataManager should not log if there are

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hi John, Thank you. I think it makes sense to modify the KIP to add the prefixScan() as part of the existing interfaces and add the new mixin behaviour as Rejected alternatives. I am not very aware of other stores apart from keyValueStore so is it fine if I keep it there for now? Regarding the