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

See

[jira] [Resolved] (KAFKA-12666) Fix flaky kafka.server.RaftClusterTest.testCreateClusterAndCreateListDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-12666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-12666. Resolution: Duplicate > Fix flaky > kafka.server.RaftClusterTest.testCrea

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

Thanks Omnia, makes sense to me. > Customers who have their customised ReplicationPolicy will need to add the definition of their internal topics naming convention I wonder should we include default impls in the interface to avoid that requirement? Ryanne On Sun, Apr 25, 2021, 2:20 PM Omnia Ibr

[jira] [Created] (KAFKA-12722) Evaluate moving replaceSegments into LogSegments class

Kowshik Prakasam created KAFKA-12722: Summary: Evaluate moving replaceSegments into LogSegments class Key: KAFKA-12722 URL: https://issues.apache.org/jira/browse/KAFKA-12722 Project: Kafka

[jira] [Created] (KAFKA-12721) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsAllTopicsAllGroups

A. Sophie Blee-Goldman created KAFKA-12721: -- Summary: Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsAllTopicsAllGroups Key: KAFKA-12721 URL: https://issues.apache.org/jira/browse/KAFKA-12721

[jira] [Resolved] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-6435. --- Resolution: Fixed > Application Reset Tool might delete incorrect internal to

Re: [DISCUSS] KIP-735: Increase default consumer session timeout

Thanks all for the comments. It sounds like this is not too controversial, so I will move this to a vote tomorrow or the next day. Best, Jason On Tue, Apr 27, 2021 at 1:54 AM David Jacot wrote: > Thanks for the KIP, Jason. The proposed changes sound good to me. > > Best, > David > > On Tue, Apr

Re: [DISCUSS] KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp

Hi Tom, I had the same question as David. It sounds like this will require a bump to the `ListOffsets` API? Otherwise, looking at the code, the sentinel would be interpreted as a timestamp query and it looks like it would end up returning the smallest timestamp ;). A second thought I had is wheth

[jira] [Created] (KAFKA-12720) Ecosystem wiki page: Kafka Manager renamed CMAK (Cluster Manager for Apache Kafka)

Philippe Cloutier created KAFKA-12720: - Summary: Ecosystem wiki page: Kafka Manager renamed CMAK (Cluster Manager for Apache Kafka) Key: KAFKA-12720 URL: https://issues.apache.org/jira/browse/KAFKA-12720

[DISCUSS] KIP-736: Report the true end to end fetch latency

Hi All, I'd like to open up the discussion on a KIP-736. This is to report the "real" fetch latency by removing the effects of waiting due to replica.fetch.wait.max.ms or fetch.min.bytes. Please give it a look over and let me know what you think. https://cwiki.apache.org/confluence/display/KAFKA

[jira] [Resolved] (KAFKA-12719) Kafka MirrorMaker 2 can only mirror in one direction in Active/Active config

[ https://issues.apache.org/jira/browse/KAFKA-12719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bui Thanh MInh resolved KAFKA-12719. Resolution: Auto Closed Need to restart all mm2 instances > Kafka MirrorMaker 2 can only

Re: [VOTE] KIP-567: Auditing in Kafka

Bumping it in hope for any feedback. On Fri, Mar 12, 2021 at 3:49 PM Viktor Somogyi-Vass wrote: > Hi Everyone, > > It seems people don't have anything to add on the discussion, so I'd like > to propose a vote now. In any case if you still have something to add, > please feel free to write either

Re: [DISCUSS] KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp

Hey Thomas, Thanks for the KIP. I have few comments/questions about it: 1. It would be great if we could better explain why we need this in the motivation. At the moment, it only explains what will be added. 2. You plan to add the `MAX_TIMESTAMP` constant to tell the broker to return the maximum

[jira] [Created] (KAFKA-12719) Kafka MirrorMaker 2 can only mirror in one direction in Active/Active config

Bui Thanh MInh created KAFKA-12719: -- Summary: Kafka MirrorMaker 2 can only mirror in one direction in Active/Active config Key: KAFKA-12719 URL: https://issues.apache.org/jira/browse/KAFKA-12719 Proj

Re: [DISCUSS] KIP-735: Increase default consumer session timeout

Thanks for the KIP, Jason. The proposed changes sound good to me. Best, David On Tue, Apr 27, 2021 at 2:52 AM Satish Duggana wrote: > Tthanks Jason for the clarification. > > On Tue, 27 Apr 2021 at 05:42, Jason Gustafson > wrote: > > > > Hi Satish, > > > > Typically we update the upgrade notes