[jira] [Assigned] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

[ https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9465: -- Assignee: Ted Yu > Enclose consumer call with catching InvalidOffsetException > --

[jira] [Commented] (KAFKA-9465) Enclose consumer call with catching InvalidOffsetException

[ https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17021807#comment-17021807 ] Matthias J. Sax commented on KAFKA-9465: Add you to the list of contributors – yo

[jira] [Assigned] (KAFKA-9464) Close the producer in completeShutdown

[ https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9464: -- Assignee: Ted Yu > Close the producer in completeShutdown > --

[jira] [Updated] (KAFKA-9466) Add documentation for new stream EOS change

[ https://issues.apache.org/jira/browse/KAFKA-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9466: --- Component/s: streams docs > Add documentation for new stream EOS change > --

[jira] [Updated] (KAFKA-9471) Return empty collection for PENDING_SHUTDOWN

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9471: --- Component/s: streams > Return empty collection for PENDING_SHUTDOWN > ---

[jira] [Commented] (KAFKA-9471) Return empty collection for PENDING_SHUTDOWN

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022400#comment-17022400 ] Matthias J. Sax commented on KAFKA-9471: Considering KIP-216, I think we need to

[jira] [Resolved] (KAFKA-8317) ClassCastException using KTable.suppress()

[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8317. Resolution: Duplicate Closing this ticket in favor of KAFKA-9259 that duplicates it. > Cla

[jira] [Commented] (KAFKA-9471) Throw exception for DEAD StreamThread.State

[ https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022614#comment-17022614 ] Matthias J. Sax commented on KAFKA-9471: Btw: we plan to rework some part of the

[jira] [Commented] (KAFKA-7325) Support dynamic gap session window

[ https://issues.apache.org/jira/browse/KAFKA-7325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024657#comment-17024657 ] Matthias J. Sax commented on KAFKA-7325: No. There was an initial discussion abou

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024742#comment-17024742 ] Matthias J. Sax commented on KAFKA-9450: Yes, the ticket was created because the

[jira] [Updated] (KAFKA-9477) Doc: Add RoundRobinAssignor as an option to consumer configs

[ https://issues.apache.org/jira/browse/KAFKA-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9477: --- Priority: Minor (was: Major) > Doc: Add RoundRobinAssignor as an option to consumer configs

[jira] [Updated] (KAFKA-9477) Doc: Add RoundRobinAssignor as an option to consumer configs

[ https://issues.apache.org/jira/browse/KAFKA-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9477: --- Component/s: docs consumer > Doc: Add RoundRobinAssignor as an option to con

[jira] [Assigned] (KAFKA-9477) Doc: Add RoundRobinAssignor as an option to consumer configs

[ https://issues.apache.org/jira/browse/KAFKA-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9477: -- Assignee: Alexandra Rodoni > Doc: Add RoundRobinAssignor as an option to consumer conf

[jira] [Commented] (KAFKA-9477) Doc: Add RoundRobinAssignor as an option to consumer configs

[ https://issues.apache.org/jira/browse/KAFKA-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024787#comment-17024787 ] Matthias J. Sax commented on KAFKA-9477: Thanks for the ticket and PR [~arodoni]

[jira] [Commented] (KAFKA-8085) Flaky Test ResetConsumerGroupOffsetTest#testResetOffsetsByDuration

[ https://issues.apache.org/jira/browse/KAFKA-8085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025632#comment-17025632 ] Matthias J. Sax commented on KAFKA-8085: Different tes within the same class:  [h

[jira] [Commented] (KAFKA-8967) Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-8967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025633#comment-17025633 ] Matthias J. Sax commented on KAFKA-8967: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025634#comment-17025634 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025635#comment-17025635 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-5676) MockStreamsMetrics should be in o.a.k.test

[ https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17026076#comment-17026076 ] Matthias J. Sax commented on KAFKA-5676: This ticket is marked in "in progress" b

[jira] [Resolved] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9445. Fix Version/s: 2.5.0 Resolution: Fixed > Allow fetching a key from a single partitio

[jira] [Resolved] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7658. Fix Version/s: 2.5.0 Resolution: Fixed > Add KStream#toTable to the Streams DSL > --

[jira] [Updated] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9483: --- Component/s: streams > Add Scala KStream#toTable to the Streams DSL > ---

[jira] [Updated] (KAFKA-9487) Followup : KAFKA-9445

[ https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9487: --- Fix Version/s: 2.5.0 > Followup : KAFKA-9445 > - > > Key:

[jira] [Updated] (KAFKA-9487) Followup : KAFKA-9445

[ https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9487: --- Priority: Blocker (was: Major) > Followup : KAFKA-9445 > - > >

[jira] [Commented] (KAFKA-9487) Followup : KAFKA-9445

[ https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027737#comment-17027737 ] Matthias J. Sax commented on KAFKA-9487: We merge the original feature PR to meet

[jira] [Assigned] (KAFKA-9490) Some factory methods in Grouped are missing generic parameters

[ https://issues.apache.org/jira/browse/KAFKA-9490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9490: -- Assignee: Matthias J. Sax > Some factory methods in Grouped are missing generic parame

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028188#comment-17028188 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028191#comment-17028191 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028192#comment-17028192 ] Matthias J. Sax commented on KAFKA-8110: Also `testDescribeGroupMembersWithShortI

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028193#comment-17028193 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9007) Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover

[ https://issues.apache.org/jira/browse/KAFKA-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028508#comment-17028508 ] Matthias J. Sax commented on KAFKA-9007: This also failed for SaslSslCosumerTest

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028509#comment-17028509 ] Matthias J. Sax commented on KAFKA-8211: [https://builds.apache.org/job/kafka-pr-

[jira] [Created] (KAFKA-9495) Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk

Matthias J. Sax created KAFKA-9495: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldListReassignmentsTriggeredByZk Key: KAFKA-9495 URL: https://issues.apache.org/jira/browse/KAFKA-9495 Proje

[jira] [Created] (KAFKA-9496) Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads

Matthias J. Sax created KAFKA-9496: -- Summary: Flaky Test SslAdminIntegrationTest#testSynchronousAuthorizerAclUpdatesBlockRequestThreads Key: KAFKA-9496 URL: https://issues.apache.org/jira/browse/KAFKA-9496

[jira] [Commented] (KAFKA-8015) Flaky Test SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeTopicAutoCreateTopicCreateAcl

[ https://issues.apache.org/jira/browse/KAFKA-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028510#comment-17028510 ] Matthias J. Sax commented on KAFKA-8015: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028511#comment-17028511 ] Matthias J. Sax commented on KAFKA-8211: Similar error in testResetOffsetsAllTopi

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028512#comment-17028512 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028513#comment-17028513 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028514#comment-17028514 ] Matthias J. Sax commented on KAFKA-8211: [https://builds.apache.org/job/kafka-pr-

[jira] [Created] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

Matthias J. Sax created KAFKA-9501: -- Summary: Promote Standby tasks to active tasks without closing them Key: KAFKA-9501 URL: https://issues.apache.org/jira/browse/KAFKA-9501 Project: Kafka

[jira] [Created] (KAFKA-9502) Use explicit "purge data" for windowed changelog topics instead of "delete,compact" topic config

Matthias J. Sax created KAFKA-9502: -- Summary: Use explicit "purge data" for windowed changelog topics instead of "delete,compact" topic config Key: KAFKA-9502 URL: https://issues.apache.org/jira/browse/KAFKA-9502

[jira] [Updated] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

[ https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9503: --- Component/s: streams-test-utils > TopologyTestDriver processes intermediate results in the wr

[jira] [Updated] (KAFKA-9500) Foreign-Key Join creates an invalid topology

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9500: --- Component/s: streams > Foreign-Key Join creates an invalid topology > ---

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029411#comment-17029411 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029413#comment-17029413 ] Matthias J. Sax commented on KAFKA-8211: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029412#comment-17029412 ] Matthias J. Sax commented on KAFKA-8110: Different test: testDescribeGroupWithSho

[jira] [Assigned] (KAFKA-6607) Consumer Client and Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6607: -- Assignee: Matthias J. Sax > Consumer Client and Kafka Streams lag not zero when input

[jira] [Updated] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9381: --- Fix Version/s: 2.5.0 > kafka-streams-scala: Javadocs + Scaladocs not published on maven centr

[jira] [Commented] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030242#comment-17030242 ] Matthias J. Sax commented on KAFKA-9381: Thanks for picking this one up [~mumrah]

[jira] [Updated] (KAFKA-9381) kafka-streams-scala: Javadocs + Scaladocs not published on maven central

[ https://issues.apache.org/jira/browse/KAFKA-9381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9381: --- Priority: Blocker (was: Major) > kafka-streams-scala: Javadocs + Scaladocs not published on

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031114#comment-17031114 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031115#comment-17031115 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031116#comment-17031116 ] Matthias J. Sax commented on KAFKA-8211: [https://builds.apache.org/job/kafka-pr-

[jira] [Created] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

Matthias J. Sax created KAFKA-9512: -- Summary: Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration Key: KAFKA-9512 URL: https://issues.apache.org/jira/browse/KAFKA-9512 Project: Kafka

[jira] [Assigned] (KAFKA-9512) Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRestoration

[ https://issues.apache.org/jira/browse/KAFKA-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9512: -- Assignee: Vinoth Chandar > Flaky Test LagFetchIntegrationTest.shouldFetchLagsDuringRes

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031119#comment-17031119 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8266) Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup`

[ https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031121#comment-17031121 ] Matthias J. Sax commented on KAFKA-8266: This test is rather flaky, cf. KAFKA-796

[jira] [Commented] (KAFKA-9007) Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover

[ https://issues.apache.org/jira/browse/KAFKA-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031122#comment-17031122 ] Matthias J. Sax commented on KAFKA-9007: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031767#comment-17031767 ] Matthias J. Sax commented on KAFKA-8211: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

[ https://issues.apache.org/jira/browse/KAFKA-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031770#comment-17031770 ] Matthias J. Sax commented on KAFKA-8245: Different test `testDeleteEmptyGroup` is

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8940: Reopening. Failed again:  [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4521/testRepo

[jira] [Created] (KAFKA-9516) Flaky Test PlaintextProducerSendTest#testNonBlockingProducer

Matthias J. Sax created KAFKA-9516: -- Summary: Flaky Test PlaintextProducerSendTest#testNonBlockingProducer Key: KAFKA-9516 URL: https://issues.apache.org/jira/browse/KAFKA-9516 Project: Kafka

[jira] [Updated] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9518: --- Description: I have a KafkaStreams that dinamically builds a topology based on a Map of inpu

[jira] [Updated] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9518: --- Description: I have a KafkaStreams that dinamically builds a topology based on a Map of inpu

[jira] [Commented] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031935#comment-17031935 ] Matthias J. Sax commented on KAFKA-9518: I am not sure if we can provide a better

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031940#comment-17031940 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[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&focusedCommentId=17031942#comment-17031942 ] Matthias J. Sax commented on KAFKA-8940: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031946#comment-17031946 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031944#comment-17031944 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[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&focusedCommentId=17031949#comment-17031949 ] Matthias J. Sax commented on KAFKA-8940: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031948#comment-17031948 ] Matthias J. Sax commented on KAFKA-8264: [https://builds.apache.org/job/kafka-pr-

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031949#comment-17031949 ] Matthias J. Sax edited comment on KAFKA-8940 at 2/6/20 9:28 PM: ---

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8940. Resolution: Fixed Nevermind. The test is fine. The PR broke the test. Can reproduce it loca

[jira] [Commented] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032663#comment-17032663 ] Matthias J. Sax commented on KAFKA-9518: Thanks for digging out the other Jira [~

[jira] [Resolved] (KAFKA-9248) Foreign key join does not pickup default serdes and dies with NPE

[ https://issues.apache.org/jira/browse/KAFKA-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9248. Resolution: Duplicate Agreed. Closing this ticket as duplicate. > Foreign key join does no

[jira] [Updated] (KAFKA-9526) Augment topology description with serdes

[ https://issues.apache.org/jira/browse/KAFKA-9526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9526: --- Component/s: streams > Augment topology description with serdes > ---

[jira] [Updated] (KAFKA-9523) Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest

[ https://issues.apache.org/jira/browse/KAFKA-9523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9523: --- Component/s: unit tests streams > Reduce flakiness of BranchedMultiLevelRepa

[jira] [Updated] (KAFKA-9526) Augment topology description with serdes

[ https://issues.apache.org/jira/browse/KAFKA-9526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9526: --- Labels: needs-kip (was: ) > Augment topology description with serdes > -

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032984#comment-17032984 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032983#comment-17032983 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033129#comment-17033129 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8211) Flaky Test: ResetConsumerGroupOffsetTest.testResetOffsetsExportImportPlan

[ https://issues.apache.org/jira/browse/KAFKA-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033282#comment-17033282 ] Matthias J. Sax commented on KAFKA-8211: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033326#comment-17033326 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033327#comment-17033327 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034661#comment-17034661 ] Matthias J. Sax commented on KAFKA-9013: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034885#comment-17034885 ] Matthias J. Sax commented on KAFKA-9530: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8110) Flaky Test DescribeConsumerGroupTest#testDescribeMembersWithConsumersWithoutAssignedPartitions

[ https://issues.apache.org/jira/browse/KAFKA-8110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034887#comment-17034887 ] Matthias J. Sax commented on KAFKA-8110: [https://builds.apache.org/job/kafka-pr-

[jira] [Issue Comment Deleted] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9530: --- Comment: was deleted (was: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4643/test

[jira] [Commented] (KAFKA-9530) Flaky Test kafka.admin.DescribeConsumerGroupTest.testDescribeGroupWithShortInitializationTimeout

[ https://issues.apache.org/jira/browse/KAFKA-9530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034886#comment-17034886 ] Matthias J. Sax commented on KAFKA-9530: [https://builds.apache.org/job/kafka-pr-

[jira] [Resolved] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9483. Fix Version/s: 2.5.0 Resolution: Fixed > Add Scala KStream#toTable to the Streams DS

[jira] [Updated] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

[ https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9503: --- Fix Version/s: 2.4.1 2.5.0 > TopologyTestDriver processes intermediate res

[jira] [Updated] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9509: --- Affects Version/s: (was: 2.4.1, 2.5.0) > Fix flaky test MirrorConnectorsIntegrationTest.t

[jira] [Updated] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9509: --- Fix Version/s: 2.5.0 > Fix flaky test MirrorConnectorsIntegrationTest.testReplication > -

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1703#comment-1703 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9535: --- Affects Version/s: (was: 2.5.0) (was: 2.4.0) > Metadata not up

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Summary: Kafka Streams lag not zero when input topic transactional (was: Consumer Client and

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Component/s: (was: clients) > Kafka Streams lag not zero when input topic transactional >

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Description: When an input topic for a Kafka Streams application is written using transactio

[jira] [Resolved] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6607. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Streams lag not zero when input topic

[jira] [Updated] (KAFKA-6607) Kafka Streams lag not zero when input topic transactional

[ https://issues.apache.org/jira/browse/KAFKA-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6607: --- Description: When an input topic for a Kafka Streams application is written using transactio

<    2   3   4   5   6   7   8   9   10   11   >