[jira] [Resolved] (KAFKA-12206) o.a.k.common.Uuid should implement Comparable

[ https://issues.apache.org/jira/browse/KAFKA-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12206. Fix Version/s: 2.8.0 Assignee: Colin McCabe Resolution: Fixed >

Jenkins build is back to normal : Kafka » kafka-2.7-jdk8 #107

See

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

See Changes: [github] KAFKA-10793: move handling of FindCoordinatorFuture to fix race condition (#9671) [github] MINOR: Fix meaningless message in assertNull validation (#9965)

[jira] [Resolved] (KAFKA-12233) Align the length passed to FileChannel by `FileRecords.writeTo`

[ https://issues.apache.org/jira/browse/KAFKA-12233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12233. Fix Version/s: 2.8.0 Resolution: Fixed > Align the length passed to FileChannel by

[jira] [Resolved] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-10793. Fix Version/s: 2.7.1 Resolution: Fixed > Race condition in

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #410

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #440

See

[GitHub] [kafka-site] showuon opened a new pull request #325: MINOR: Remove redundant apostrophe in doc

showuon opened a new pull request #325: URL: https://github.com/apache/kafka-site/pull/325 Found a redundant apostrophe appeared in doc. 

Jenkins build is back to normal : Kafka » kafka-2.3-jdk8 #15

See

[DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hello all, I’d like to start discussion on KIP-708 [1] that aims to introduce rack aware standby task distribution in Kafka Streams. In addition to changes mentioned in the KIP, I’d like to get some ideas on additional change I have in mind. Assuming KIP moves forward, I was wondering if it

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

See Changes: [Konstantine Karantasis] KAFKA-10763: Fix incomplete cooperative rebalances preventing connector/task revocations (#9765) -- [...truncated 3.44

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #76

See Changes: [Konstantine Karantasis] KAFKA-10763: Fix incomplete cooperative rebalances preventing connector/task revocations (#9765) -- [...truncated 3.17

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

See Changes: [github] MINOR: set initial capacity of ArrayList for all json converters (#9962) [github] KAFKA-10763: Fix incomplete cooperative rebalances preventing connector/task revocations

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

See Changes: [github] MINOR: set initial capacity of ArrayList for all json converters (#9962) [github] KAFKA-10763: Fix incomplete cooperative rebalances preventing connector/task revocations

Re: 2.6.1 Critical Regression

Hi Gary, Thanks for raising this. Looking at the PR, the change is in kafka streams, not clients? Ismael On Tue, Jan 26, 2021 at 12:39 PM Gary Russell wrote: > A critical regression was included in kafka-clients 2.6.1, which is now > fixed and cherry picked [1]. > > For some devs, it is not

2.6.1 Critical Regression

A critical regression was included in kafka-clients 2.6.1, which is now fixed and cherry picked [1]. For some devs, it is not easy (or they are not allowed by their enterprise) to move up to a new release, even a minor release (2.7). Devs are often allowed to upgrade to patch releases without

[jira] [Created] (KAFKA-12243) Add toString methods to some of the classes introduced by this Epic

Jose Armando Garcia Sancio created KAFKA-12243: -- Summary: Add toString methods to some of the classes introduced by this Epic Key: KAFKA-12243 URL: https://issues.apache.org/jira/browse/KAFKA-12243

[jira] [Resolved] (KAFKA-10763) Task already exists error on same worker due to skip removal of tasks

[ https://issues.apache.org/jira/browse/KAFKA-10763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10763. Resolution: Fixed > Task already exists error on same worker due to skip

[jira] [Created] (KAFKA-12242) Decouple state store materialization enforcement from name/serde provider

Guozhang Wang created KAFKA-12242: - Summary: Decouple state store materialization enforcement from name/serde provider Key: KAFKA-12242 URL: https://issues.apache.org/jira/browse/KAFKA-12242 Project:

[jira] [Created] (KAFKA-12241) Partition offline when ISR shrinks to leader and LogDir goes offline

Noa Resare created KAFKA-12241: -- Summary: Partition offline when ISR shrinks to leader and LogDir goes offline Key: KAFKA-12241 URL: https://issues.apache.org/jira/browse/KAFKA-12241 Project: Kafka

[jira] [Resolved] (KAFKA-10694) Implement zero copy for FetchSnapshot

[ https://issues.apache.org/jira/browse/KAFKA-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10694. - Resolution: Fixed > Implement zero copy for FetchSnapshot >

Re: Kafka Advisory Topic

Gwen, Yes, Chris and I work together; we can put together a KIP. If someone would please grant me wiki permissions, username is katchison. Thank you. On Mon, Jan 25, 2021 at 2:58 PM Gwen Shapira wrote: > Agree that this sounds like a good idea. > > Would be good to have a more formal

[jira] [Created] (KAFKA-12240) Proposal for Log layer refactoring

Kowshik Prakasam created KAFKA-12240: Summary: Proposal for Log layer refactoring Key: KAFKA-12240 URL: https://issues.apache.org/jira/browse/KAFKA-12240 Project: Kafka Issue Type:

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #408

See

[jira] [Created] (KAFKA-12239) Unclear warning message in JmxReporter, when getting missing JMX attribute

Gérald Quintana created KAFKA-12239: --- Summary: Unclear warning message in JmxReporter, when getting missing JMX attribute Key: KAFKA-12239 URL: https://issues.apache.org/jira/browse/KAFKA-12239

[DISCUSS] KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Hello everyone, I would like to start a discussion on KIP-709, which addresses some missing features in MM2 dedicated mode. https://cwiki.apache.org/confluence/display/KAFKA/KIP-710%3A+Full+support+for+distributed+mode+in+dedicated+MirrorMaker+2.0+clusters Currently, the dedicated mode of MM2

Re: [DISCUSS] KIP-709: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Hi Tom, Sure, will increment. Sorry for the confusion, I just started using the next number, but did not check the KIP list. Thanks, Daniel Thomas Scott ezt írta (időpont: 2021. jan. 26., K, 10:58): > Hi Daniel, > > It seems we have duplicate KIP-709s. Can we move this one to KIP-710? > >

Re: [DISCUSS] KIP-709: Extend OffsetFetch requests to accept multiple group ids

Thanks David I've updated it. On Tue, Jan 26, 2021 at 1:55 PM David Jacot wrote: > Great. That answers my question! > > Thomas, I suggest adding a Related/Future Work section in the > KIP to link KIP-699 more explicitly. > > Thanks, > David > > On Tue, Jan 26, 2021 at 1:30 PM Thomas Scott

Re: [DISCUSS] KIP-709: Extend OffsetFetch requests to accept multiple group ids

Great. That answers my question! Thomas, I suggest adding a Related/Future Work section in the KIP to link KIP-699 more explicitly. Thanks, David On Tue, Jan 26, 2021 at 1:30 PM Thomas Scott wrote: > Hi Mickael/David, > > I feel like the combination of these 2 KIPs gives the complete

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

See Changes: [github] MINOR: remove unused code from MessageTest (#9961) -- [...truncated 3.58 MB...] TestTopicsTest > testEmptyTopic() STARTED

Re: [DISCUSS] KIP-709: Extend OffsetFetch requests to accept multiple group ids

Hi Mickael/David, I feel like the combination of these 2 KIPs gives the complete solution but they can be implemented independently. I have added a description and links to KIP-699 to KIP-709 to this effect. Thanks Tom On Tue, Jan 26, 2021 at 11:44 AM Mickael Maison wrote: > Hi Thomas,

Re: [DISCUSS] KIP-709: Extend OffsetFetch requests to accept multiple group ids

Hi Thomas, Thanks, the KIP looks good. David, I started working on exactly that a few weeks ago: https://cwiki.apache.org/confluence/display/KAFKA/KIP-699%3A+FindCoordinators I hope to complete my draft and start a discussion later on this week. Thanks On Tue, Jan 26, 2021 at 10:06 AM David

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

See Changes: [github] MINOR: Fix visibility of Log.{unflushedMessages, addSegment} methods (#9966) -- [...truncated 3.55 MB...]

Re: [DISCUSS] KIP-709: Extend OffsetFetch requests to accept multiple group ids

Hi Thomas, Thanks for the KIP. Overall, the KIP looks good to me. I have only one question: The FindCoordinator API only supports resolving one group id at the time. If we want to get the offsets for say N groups, that means that we have to first issue N FindCoordinator requests, wait for the

Re: [DISCUSS] KIP-709: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Hi Daniel, It seems we have duplicate KIP-709s. Can we move this one to KIP-710? Thanks Tom On Tue, Jan 26, 2021 at 8:35 AM Dániel Urbán wrote: > Hello everyone, > > I would like to start a discussion on KIP-709, which addresses some missing > features in MM2 dedicated mode. > >

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

See Changes: [github] MINOR: Fix visibility of Log.{unflushedMessages, addSegment} methods (#9966) -- [...truncated 3.57 MB...] OutputVerifierTest >

[VOTE] KIP-709: Extend OffsetFetch requests to accept multiple group ids.

Hey all, I'd like to start the vote for https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=173084258 Thanks Tom

Re: [DISCUSS] KIP-709: Extend OffsetFetch requests to accept multiple group ids

Hi Thomas, Thanks for the KIP, this is a useful addition for admin use cases. It may be worth starting the voting thread soon if we want to get this into 2.8.0. Regards, Rajini On Mon, Jan 25, 2021 at 1:52 PM Thomas Scott wrote: > Thanks Ismael, that's a lot better. I've updated the KIP

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

See

Re: [DISCUSS] KIP-709: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

And I guess providing the link wouldn't hurt either: https://cwiki.apache.org/confluence/display/KAFKA/KIP-709%3A+Full+support+for+distributed+mode+in+dedicated+MirrorMaker+2.0+clusters On Tue, Jan 26, 2021 at 9:35 AM Dániel Urbán wrote: > Hello everyone, > > I would like to start a discussion

[DISCUSS] KIP-709: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Hello everyone, I would like to start a discussion on KIP-709, which addresses some missing features in MM2 dedicated mode. Currently, the dedicated mode of MM2 does not fully support running in a cluster. The core issue is that the Connect REST Server is not included in the dedicated mode,