Jenkins build is back to normal : Kafka » kafka-2.6-jdk8 #97

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #550

See Changes: [github] KAFKA-10817; Add clusterId validation to raft Fetch handling (#10129) [github] KAFKA-12339: Add retry to admin client's listOffsets (#10152) [Colin McCabe] KAFKA-12334: Add

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #494

See Changes: [Colin McCabe] MINOR: Fix Raft broker restart issue when offset partitions are deferred #10155 [github] KAFKA-12332; Error partitions from topics with invalid IDs in LISR requests

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #22

See Changes: [Colin McCabe] KAFKA-12276: Add the quorum controller code (#10070) [Colin McCabe] HOTFIX: fix cherry-pick to 2.8 -- [...truncated 1.80 MB...]

[jira] [Resolved] (KAFKA-12335) Upgrade junit from 5.7.0 to 5.7.1

[ https://issues.apache.org/jira/browse/KAFKA-12335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12335. Fix Version/s: 3.0.0 Resolution: Fixed > Upgrade junit from 5.7.0 to 5.7.1 >

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #525

See Changes: [Colin McCabe] MINOR: Fix Raft broker restart issue when offset partitions are deferred #10155 [github] KAFKA-12332; Error partitions from topics with invalid IDs in LISR requests

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #123

See Changes: [Randall Hauch] KAFKA-12340: Fix potential resource leak in Kafka*BackingStore (#10153) [Randall Hauch] KAFKA-12343: Handle exceptions better in TopicAdmin, including

Re: [DISCUSS] KIP-690 Add additional configuration to control MirrorMaker 2 internal topics naming convention

Hi Omnia, Thanks for the clarifications. - I'm still a bit uneasy with the overlap between these 2 methods as currently `ReplicationPolicy.isInternalTopic` already handles MM2 internal topics. Should we make it only handle Kafka internal topics and `isMM2InternalTopic()` only handle MM2 topics?

Re: [DISCUSS] Apache Kafka 2.7.1 release

Sounds good, I was just curious if you had seen problems in the wild. The following two are important too: 1. https://issues.apache.org/jira/browse/KAFKA-10793 2. https://issues.apache.org/jira/browse/KAFKA-12193 Ismael On Fri, Feb 19, 2021 at 3:24 AM Mickael Maison wrote: > Hi Ismael, > >

[GitHub] [kafka-site] showuon opened a new pull request #331: MINOR: update the old anchor #intro_topic into the new one

showuon opened a new pull request #331: URL: https://github.com/apache/kafka-site/pull/331 Accidentally found the anchor # intro_topic doesn't exist anymore, and cause the quick start page has a wrong link. Correct it as the new # intro_concepts_and_terms anchor

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #20

See Changes: [Colin McCabe] MINOR: Add KIP-500 BrokerServer and ControllerServer (#10113) [Matthias J. Sax] TRIVIAL: fix JavaDocs formatting (#10134) [Colin McCabe] Fixed README and added clearer

Re: [DISCUSS] Apache Kafka 2.7.1 release

Hi Ismael, The main motivation was to carry on releasing a bugfix 2-3 months after a release. The project has followed that process for a while now and, as far as I can tell, it works well. That said, looking at the issues, there are a few interesting fixes: - KAFKA-12323 is a regression in

[GitHub] [kafka-site] mimaison merged pull request #331: MINOR: update the old anchor #intro_topic into the new one

mimaison merged pull request #331: URL: https://github.com/apache/kafka-site/pull/331 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

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #548

See

[jira] [Created] (KAFKA-12347) Improve Kafka Streams ability to track progress

Walker Carlson created KAFKA-12347: -- Summary: Improve Kafka Streams ability to track progress Key: KAFKA-12347 URL: https://issues.apache.org/jira/browse/KAFKA-12347 Project: Kafka Issue

[jira] [Created] (KAFKA-12348) The metadata module currently uses Yammer metrics. Should it uses Kafka metrics instead?

Ron Dagostino created KAFKA-12348: - Summary: The metadata module currently uses Yammer metrics. Should it uses Kafka metrics instead? Key: KAFKA-12348 URL: https://issues.apache.org/jira/browse/KAFKA-12348

[jira] [Resolved] (KAFKA-12332) Error partitions from topics with invalid IDs in LISR requests

[ https://issues.apache.org/jira/browse/KAFKA-12332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-12332. - Resolution: Fixed > Error partitions from topics with invalid IDs in LISR requests >

Re: [DISCUSS] Apache Kafka 2.6.2 release

Thanks Randall. I think all three of those seem important and should be merged back to the 2.6 branch. On Fri, Feb 19, 2021 at 10:01 AM Randall Hauch wrote: > Hi, Sophie. > > I have three new blockers related to a previous fix applied since 2.6.1 > that I'd like to merge to the 2.6 branch: > *

Re: [DISCUSS] Apache Kafka 2.6.2 release

Hi, Sophie. I have three new blockers related to a previous fix applied since 2.6.1 that I'd like to merge to the 2.6 branch: * https://issues.apache.org/jira/browse/KAFKA-12340 -- potential resource leak for Kafka*BackingStores used in Connect; PR is already approved and in trunk *

[jira] [Created] (KAFKA-12349) Follow up on PartitionEpoch in KIP-500

Colin McCabe created KAFKA-12349: Summary: Follow up on PartitionEpoch in KIP-500 Key: KAFKA-12349 URL: https://issues.apache.org/jira/browse/KAFKA-12349 Project: Kafka Issue Type:

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #549

See Changes: [github] KAFKA-12340: Fix potential resource leak in Kafka*BackingStore (#10153) [Colin McCabe] MINOR: Fix Raft broker restart issue when offset partitions are deferred #10155

[jira] [Resolved] (KAFKA-12343) Recent change to use SharedTopicAdmin in KakfkaBasedLog fails with AK 0.10.x brokers

[ https://issues.apache.org/jira/browse/KAFKA-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-12343. --- Reviewer: Konstantine Karantasis Resolution: Fixed > Recent change to use

Re: [DISCUSS] Apache Kafka 2.6.2 release

Thanks, Sophie. Commits for all 3 issues mentioned earlier have been backported to the `2.6` branch. On Fri, Feb 19, 2021 at 2:08 PM Sophie Blee-Goldman wrote: > Thanks Randall. I think all three of those seem important and should be > merged back to the 2.6 branch. > > On Fri, Feb 19, 2021 at

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #21

See Changes: [Colin McCabe] MINOR: Fix Raft broker restart issue when offset partitions are deferred #10155 [Jason Gustafson] KAFKA-12258; Add support for splitting appending records (#10063) [Jason

Re: [DISCUSS] Apache Kafka 2.8.0 release

There are two regressions for a bugfix in Connect previously merged in 2.8: - https://issues.apache.org/jira/browse/KAFKA-12339 -- fix resource leak in Connect's Kafka*BackingStore implementations when used outside of Connect - https://issues.apache.org/jira/browse/KAFKA-12340 -- add

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

[ https://issues.apache.org/jira/browse/KAFKA-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-9672. Fix Version/s: 3.0.0 Resolution: Fixed merged the PR to trunk > Dead brokers in ISR cause

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #524

See Changes: [github] MINOR: Import classes that is used in docs to fix warnings. (#10136) [github] KAFKA-10885 Refactor MemoryRecordsBuilderTest/MemoryRecordsTest to avoid a lot of… (#9906)

[jira] [Resolved] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9274. Fix Version/s: 2.8.0 Resolution: Fixed > Gracefully handle timeout exceptions on

[jira] [Resolved] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9270. Resolution: Fixed > KafkaStream crash on offset commit failure >

[DISCUSS] KIP-149 (reloaded)

All, KIP-149 has been approved for a while now, but parts of it remain un-implemented. I have submitted a new PR adding read-only access to the join-key for KStream joins to set the value resulting from the join ( https://github.com/apache/kafka/pull/10150). The original KIP did not include

[jira] [Resolved] (KAFKA-10817) Add clusterId validation to Fetch handling

[ https://issues.apache.org/jira/browse/KAFKA-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10817. - Resolution: Fixed > Add clusterId validation to Fetch handling >