[jira] [Created] (KAFKA-12944) KIP-724: Always write record batches with message format v2

Ismael Juma created KAFKA-12944: --- Summary: KIP-724: Always write record batches with message format v2 Key: KAFKA-12944 URL: https://issues.apache.org/jira/browse/KAFKA-12944 Project: Kafka

[jira] [Assigned] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reassigned KAFKA-8940: Assignee: Luke Chen > Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance >

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1736#comment-1736 ] Luke Chen commented on KAFKA-8940: -- investigating > Flaky Test

[jira] [Updated] (KAFKA-12943) Bug in Kafka Streams Documentation (Aggregating)

[ https://issues.apache.org/jira/browse/KAFKA-12943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajesh KSV updated KAFKA-12943: --- Description: In the doc, for aggregating function, the example is incorrect

[jira] [Created] (KAFKA-12943) Bug in Kafka Streams Documentation (Aggregating)

Rajesh KSV created KAFKA-12943: -- Summary: Bug in Kafka Streams Documentation (Aggregating) Key: KAFKA-12943 URL: https://issues.apache.org/jira/browse/KAFKA-12943 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362203#comment-17362203 ] John Roesler commented on KAFKA-10091: -- Hey all, sorry for the delay. Yes! This got pulled from 2.8

[jira] [Commented] (KAFKA-3861) Shrunk ISR before leader crash makes the partition unavailable

[ https://issues.apache.org/jira/browse/KAFKA-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362202#comment-17362202 ] Jack Foy commented on KAFKA-3861: - We were affected by this same issue under Kafka 2.5.0 this week,

[jira] [Updated] (KAFKA-12942) Remove excluded Connect tests when running with JDK 16

[ https://issues.apache.org/jira/browse/KAFKA-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12942: Summary: Remove excluded Connect tests when running with JDK 16 (was: Remove Connect excluded

[jira] [Commented] (KAFKA-12850) Use JDK16 for builds instead of JDK15

[ https://issues.apache.org/jira/browse/KAFKA-12850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362067#comment-17362067 ] Ismael Juma commented on KAFKA-12850: - Instead of closing this, I made it an umbrella JIRA for the

[jira] [Commented] (KAFKA-12942) Remove Connect excluded tests when running with JDK 16

[ https://issues.apache.org/jira/browse/KAFKA-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362065#comment-17362065 ] Ismael Juma commented on KAFKA-12942: - cc [~kkonstantine] > Remove Connect excluded tests when

[jira] [Updated] (KAFKA-12940) Enable JDK 16 builds in Jenkins

[ https://issues.apache.org/jira/browse/KAFKA-12940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12940: Fix Version/s: 3.0.0 > Enable JDK 16 builds in Jenkins > --- > >

[jira] [Updated] (KAFKA-12941) Remove excluded Streams tests when running with JDK 16

[ https://issues.apache.org/jira/browse/KAFKA-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12941: Description:

[jira] [Commented] (KAFKA-12941) Remove excluded Streams tests when running with JDK 16

[ https://issues.apache.org/jira/browse/KAFKA-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362063#comment-17362063 ] Ismael Juma commented on KAFKA-12941: - cc [~vvcephei] > Remove excluded Streams tests when running

[jira] [Updated] (KAFKA-12942) Remove Connect excluded tests when running with JDK 16

[ https://issues.apache.org/jira/browse/KAFKA-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12942: Description:

[jira] [Created] (KAFKA-12941) Remove excluded Streams tests when running with JDK 16

Ismael Juma created KAFKA-12941: --- Summary: Remove excluded Streams tests when running with JDK 16 Key: KAFKA-12941 URL: https://issues.apache.org/jira/browse/KAFKA-12941 Project: Kafka Issue

[jira] [Created] (KAFKA-12942) Remove Connect excluded tests when running with JDK 16

Ismael Juma created KAFKA-12942: --- Summary: Remove Connect excluded tests when running with JDK 16 Key: KAFKA-12942 URL: https://issues.apache.org/jira/browse/KAFKA-12942 Project: Kafka Issue

[jira] [Created] (KAFKA-12940) Enable JDK 16 builds in Jenkins

Ismael Juma created KAFKA-12940: --- Summary: Enable JDK 16 builds in Jenkins Key: KAFKA-12940 URL: https://issues.apache.org/jira/browse/KAFKA-12940 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-12790) Fix SslTransportLayerTest.testUnsupportedTlsVersion with JDK 16

[ https://issues.apache.org/jira/browse/KAFKA-12790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12790: Parent: KAFKA-12850 Issue Type: Sub-task (was: Bug) > Fix

[jira] [Updated] (KAFKA-12905) Replace EasyMock and PowerMock with Mockito for NamedCacheMetricsTest

[ https://issues.apache.org/jira/browse/KAFKA-12905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-12905: Fix Version/s: 3.0.0 > Replace EasyMock and PowerMock with Mockito for NamedCacheMetricsTest >

[jira] [Resolved] (KAFKA-12924) Replace EasyMock and PowerMock with Mockito in streams module(metrics)

[ https://issues.apache.org/jira/browse/KAFKA-12924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-12924. - Fix Version/s: 3.0.0 Resolution: Fixed > Replace EasyMock and PowerMock with Mockito in

[jira] [Resolved] (KAFKA-12905) Replace EasyMock and PowerMock with Mockito for NamedCacheMetricsTest

[ https://issues.apache.org/jira/browse/KAFKA-12905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-12905. - Resolution: Fixed > Replace EasyMock and PowerMock with Mockito for NamedCacheMetricsTest >

[jira] [Resolved] (KAFKA-10585) Kafka Streams should clean up the state store directory from cleanup

[ https://issues.apache.org/jira/browse/KAFKA-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-10585. --- Fix Version/s: 3.0.0 Resolution: Fixed > Kafka Streams should clean up the state

[jira] [Commented] (KAFKA-10546) KIP-478: Deprecate the old PAPI interfaces

[ https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362037#comment-17362037 ] John Roesler commented on KAFKA-10546: -- Thanks, [~guozhang] !   Here's the PR:

[jira] [Commented] (KAFKA-10546) KIP-478: Deprecate the old PAPI interfaces

[ https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362032#comment-17362032 ] Guozhang Wang commented on KAFKA-10546: --- Thanks [~vvcephei], I also agree with your decision. >

[jira] [Created] (KAFKA-12939) After migrating processors, search the codebase for missed migrations

John Roesler created KAFKA-12939: Summary: After migrating processors, search the codebase for missed migrations Key: KAFKA-12939 URL: https://issues.apache.org/jira/browse/KAFKA-12939 Project: Kafka

[jira] [Commented] (KAFKA-10546) KIP-478: Deprecate the old PAPI interfaces

[ https://issues.apache.org/jira/browse/KAFKA-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361992#comment-17361992 ] John Roesler commented on KAFKA-10546: -- Rather than continuing to block the public API deprecation

[jira] [Updated] (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 ] Matthias J. Sax updated KAFKA-6435: --- Labels: bug help-wanted kip newbie (was: bug help-wanted needs-kip newbie) > Application

[jira] [Updated] (KAFKA-10434) Remove deprecated methods on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-10434: Labels: (was: needs-kip) > Remove deprecated methods on WindowStore >

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361941#comment-17361941 ] Matthias J. Sax commented on KAFKA-10091: - I thought this is completed and shipped with 2.8.0 ?

[jira] [Updated] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12849: Description: In KIP-740 we had to go through a deprecation cycle in order to change the

[jira] [Updated] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12849: Labels: kip newbie newbie++ (was: needs-kip newbie newbie++) > Consider migrating

[jira] [Commented] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361932#comment-17361932 ] Boyang Chen commented on KAFKA-10733: - Hey [~kkonstantine] I don't think anyone has cycles to push

[jira] [Updated] (KAFKA-7739) Kafka Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-7739: -- Labels: needs-kip (was: ) > Kafka Tiered Storage > > >

[jira] [Created] (KAFKA-12938) Fix and reenable testChrootExistsAndRootIsLocked

Igor Soarez created KAFKA-12938: --- Summary: Fix and reenable testChrootExistsAndRootIsLocked Key: KAFKA-12938 URL: https://issues.apache.org/jira/browse/KAFKA-12938 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9366) Upgrade log4j to log4j2

[ https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9366: -- Fix Version/s: 3.0.0 > Upgrade log4j to log4j2 > --- > >

[jira] [Updated] (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 ] Konstantine Karantasis updated KAFKA-6435: -- Labels: bug help-wanted needs-kip newbie (was: bug help-wanted newbie) >

[jira] [Updated] (KAFKA-10434) Remove deprecated methods on WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10434: --- Labels: needs-kip (was: ) > Remove deprecated methods on WindowStore >

[jira] [Updated] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10733: --- Fix Version/s: 3.0.0 > Enforce exception thrown for KafkaProducer txn APIs

[jira] [Updated] (KAFKA-10619) Producer will enable EOS by default

[ https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10619: --- Labels: needs-kip (was: ) > Producer will enable EOS by default >

[jira] [Updated] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10091: --- Labels: needs-kip (was: ) > Improve task idling > --- > >

[jira] [Updated] (KAFKA-12663) Update FindCoordinator to resolve multiple Coordinators at a time

[ https://issues.apache.org/jira/browse/KAFKA-12663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12663: --- Labels: needs-kip (was: ) > Update FindCoordinator to resolve multiple

[jira] [Updated] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-10357: --- Labels: needs-kip (was: ) > Handle accidental deletion of

[jira] [Updated] (KAFKA-6987) Reimplement KafkaFuture with CompletableFuture

[ https://issues.apache.org/jira/browse/KAFKA-6987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6987: -- Labels: needs-kip (was: ) > Reimplement KafkaFuture with CompletableFuture >

[jira] [Updated] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-6718: -- Fix Version/s: 3.0.0 > Rack Aware Stand-by Task Assignment for Kafka Streams >

[jira] [Updated] (KAFKA-12436) deprecate MirrorMaker v1

[ https://issues.apache.org/jira/browse/KAFKA-12436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12436: --- Labels: needs-kip (was: ) > deprecate MirrorMaker v1 >

[jira] [Updated] (KAFKA-12234) Extend OffsetFetch requests to accept multiple group ids.

[ https://issues.apache.org/jira/browse/KAFKA-12234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12234: --- Labels: needs-kip (was: ) > Extend OffsetFetch requests to accept multiple

[jira] [Updated] (KAFKA-12882) Add RegisteredBrokerCount and UnfencedBrokerCount metrics to the QuorumController

[ https://issues.apache.org/jira/browse/KAFKA-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12882: --- Labels: needs-kip (was: ) > Add RegisteredBrokerCount and

[jira] [Updated] (KAFKA-12620) Producer IDs generated by the controller

[ https://issues.apache.org/jira/browse/KAFKA-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12620: --- Fix Version/s: 3.0.0 > Producer IDs generated by the controller >

[jira] [Updated] (KAFKA-12620) Producer IDs generated by the controller

[ https://issues.apache.org/jira/browse/KAFKA-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12620: --- Labels: needs-kip (was: ) > Producer IDs generated by the controller >

[jira] [Updated] (KAFKA-12541) AdminClient.listOffsets should return the offset for the record with highest timestamp

[ https://issues.apache.org/jira/browse/KAFKA-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12541: --- Labels: needs-kip (was: ) > AdminClient.listOffsets should return the

[jira] [Updated] (KAFKA-12541) AdminClient.listOffsets should return the offset for the record with highest timestamp

[ https://issues.apache.org/jira/browse/KAFKA-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12541: --- Fix Version/s: 3.0.0 > AdminClient.listOffsets should return the offset for

[jira] [Updated] (KAFKA-4793) Kafka Connect: POST /connectors/(string: name)/restart doesn't start failed tasks

[ https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-4793: -- Fix Version/s: 3.0.0 > Kafka Connect: POST /connectors/(string: name)/restart

[jira] [Updated] (KAFKA-12882) Add RegisteredBrokerCount and UnfencedBrokerCount metrics to the QuorumController

[ https://issues.apache.org/jira/browse/KAFKA-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-12882: --- Fix Version/s: 3.0.0 > Add RegisteredBrokerCount and UnfencedBrokerCount

[jira] [Updated] (KAFKA-7632) Support Compression Level

[ https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-7632: -- Fix Version/s: 3.0.0 > Support Compression Level > - >

[jira] [Updated] (KAFKA-12937) Mirrormaker2 can only start from the beginning of a topic

[ https://issues.apache.org/jira/browse/KAFKA-12937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daan Bosch updated KAFKA-12937: --- Description: *Goal*: I want to replace Mirrormaker version 1 with Mirrormaker2. To do this I want

[jira] [Comment Edited] (KAFKA-12847) Dockerfile needed for kafka system tests needs changes

[ https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361575#comment-17361575 ] Abhijit Mane edited comment on KAFKA-12847 at 6/11/21, 1:54 PM: Thanks

[jira] [Updated] (KAFKA-12937) Mirrormaker2 can only start from the beginning of a topic

[ https://issues.apache.org/jira/browse/KAFKA-12937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daan Bosch updated KAFKA-12937: --- Description: *Goal*: I want to replace Mirrormaker version 1 with Mirrormaker2. To do this I want

[jira] [Created] (KAFKA-12937) Mirrormaker2 can only start from the beginning of a topic

Daan Bosch created KAFKA-12937: -- Summary: Mirrormaker2 can only start from the beginning of a topic Key: KAFKA-12937 URL: https://issues.apache.org/jira/browse/KAFKA-12937 Project: Kafka Issue

[jira] [Commented] (KAFKA-12849) Consider migrating TaskMetadata to interface with internal implementation

[ https://issues.apache.org/jira/browse/KAFKA-12849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361590#comment-17361590 ] Josep Prat commented on KAFKA-12849: Just for documentation purposes on Jira. KIP was approved and

[jira] [Commented] (KAFKA-12847) Dockerfile needed for kafka system tests needs changes

[ https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361575#comment-17361575 ] Abhijit Mane commented on KAFKA-12847: -- Thanks [~chia7712] for putting up with all my queries

[jira] [Commented] (KAFKA-10269) AdminClient ListOffsetsResultInfo/timestamp is always -1

[ https://issues.apache.org/jira/browse/KAFKA-10269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361464#comment-17361464 ] Dongjin Lee commented on KAFKA-10269: - [~d-t-w] > is it difficult or expensive to return the

[jira] [Commented] (KAFKA-10269) AdminClient ListOffsetsResultInfo/timestamp is always -1

[ https://issues.apache.org/jira/browse/KAFKA-10269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361436#comment-17361436 ] Derek Troy-West commented on KAFKA-10269: - Thanks [~dongjin] for the information. One question