[jira] [Updated] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13549: Labels: kip (was: needs-kip) > Add "delete interval" config >

[jira] [Assigned] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13549: --- Assignee: Nicholas Telford > Add "delete interval" config >

[jira] [Updated] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13549: Description: KIP-811:

[jira] [Commented] (KAFKA-13549) Add "delete interval" config

[ https://issues.apache.org/jira/browse/KAFKA-13549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461738#comment-17461738 ] Matthias J. Sax commented on KAFKA-13549: - You could also just do the KIP. Should not be too

[jira] [Created] (KAFKA-13555) Consider number if input topic partitions for task assignment

Matthias J. Sax created KAFKA-13555: --- Summary: Consider number if input topic partitions for task assignment Key: KAFKA-13555 URL: https://issues.apache.org/jira/browse/KAFKA-13555 Project: Kafka

[jira] [Commented] (KAFKA-13476) Streams crashes when non Base64 Offset Metadata is found

[ https://issues.apache.org/jira/browse/KAFKA-13476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461160#comment-17461160 ] Matthias J. Sax commented on KAFKA-13476: - {quote}Tracing data was added to metadata because

[jira] [Created] (KAFKA-13549) Add "delete interval" config

Matthias J. Sax created KAFKA-13549: --- Summary: Add "delete interval" config Key: KAFKA-13549 URL: https://issues.apache.org/jira/browse/KAFKA-13549 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-13500) Consider adding a dedicated standby consumer

[ https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457487#comment-17457487 ] Matthias J. Sax commented on KAFKA-13500: - Right... My bad. > Consider adding a dedicated

[jira] [Comment Edited] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456993#comment-17456993 ] Matthias J. Sax edited comment on KAFKA-8115 at 12/10/21, 9:14 AM: --- One

[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456993#comment-17456993 ] Matthias J. Sax commented on KAFKA-8115: One more on 3.1. > Flaky Test

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456992#comment-17456992 ] Matthias J. Sax commented on KAFKA-13530: - Again. > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456991#comment-17456991 ] Matthias J. Sax commented on KAFKA-8115: Failed again. > Flaky Test

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456990#comment-17456990 ] Matthias J. Sax commented on KAFKA-13530: - +1 > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456989#comment-17456989 ] Matthias J. Sax commented on KAFKA-12377: - One more. > Flaky Test

[jira] [Created] (KAFKA-13532) Flaky test KafkaStreamsTest.testInitializesAndDestroysMetricsReporters

Matthias J. Sax created KAFKA-13532: --- Summary: Flaky test KafkaStreamsTest.testInitializesAndDestroysMetricsReporters Key: KAFKA-13532 URL: https://issues.apache.org/jira/browse/KAFKA-13532

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456986#comment-17456986 ] Matthias J. Sax commented on KAFKA-12377: - One more on 3.1 branch. > Flaky Test

[jira] [Created] (KAFKA-13531) Flaky test NamedTopologyIntegrationTest

Matthias J. Sax created KAFKA-13531: --- Summary: Flaky test NamedTopologyIntegrationTest Key: KAFKA-13531 URL: https://issues.apache.org/jira/browse/KAFKA-13531 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-12933) Flaky test ReassignPartitionsIntegrationTest.testReassignmentWithAlterIsrDisabled

[ https://issues.apache.org/jira/browse/KAFKA-12933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12933. - Resolution: Fixed > Flaky test >

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456981#comment-17456981 ] Matthias J. Sax commented on KAFKA-13530: - And again. > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-13514) Flakey test StickyAssignorTest

[ https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456982#comment-17456982 ] Matthias J. Sax commented on KAFKA-13514: - And one more. > Flakey test StickyAssignorTest >

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456978#comment-17456978 ] Matthias J. Sax commented on KAFKA-13530: - And one more. > Flaky test ReplicaManagerTest >

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456976#comment-17456976 ] Matthias J. Sax commented on KAFKA-12377: - And one more. > Flaky Test

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456973#comment-17456973 ] Matthias J. Sax commented on KAFKA-12377: - One more. > Flaky Test

[jira] [Commented] (KAFKA-13514) Flakey test StickyAssignorTest

[ https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456970#comment-17456970 ] Matthias J. Sax commented on KAFKA-13514: - Failed again. [~ableegoldman] Could you help

[jira] [Commented] (KAFKA-13530) Flaky test ReplicaManagerTest

[ https://issues.apache.org/jira/browse/KAFKA-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456968#comment-17456968 ] Matthias J. Sax commented on KAFKA-13530: - Failed a second time. > Flaky test

[jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit()

[ https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456967#comment-17456967 ] Matthias J. Sax commented on KAFKA-12319: - Failed again. > Flaky test >

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456966#comment-17456966 ] Matthias J. Sax commented on KAFKA-12377: - Failed again. > Flaky Test

[jira] [Created] (KAFKA-13530) Flaky test ReplicaManagerTest

Matthias J. Sax created KAFKA-13530: --- Summary: Flaky test ReplicaManagerTest Key: KAFKA-13530 URL: https://issues.apache.org/jira/browse/KAFKA-13530 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-13500) Consider adding a dedicated standby consumer

[ https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456955#comment-17456955 ] Matthias J. Sax commented on KAFKA-13500: - Not 100% sure: for individual configs, maybe. – But

[jira] [Comment Edited] (KAFKA-13500) Consider adding a dedicated standby consumer

[ https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456955#comment-17456955 ] Matthias J. Sax edited comment on KAFKA-13500 at 12/10/21, 8:32 AM:

[jira] [Commented] (KAFKA-13500) Consider adding a dedicated standby consumer

[ https://issues.apache.org/jira/browse/KAFKA-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456061#comment-17456061 ] Matthias J. Sax commented on KAFKA-13500: - I guess it's related. If the restoration thread is

[jira] [Created] (KAFKA-13514) Flakey test StickyAssignorTest

Matthias J. Sax created KAFKA-13514: --- Summary: Flakey test StickyAssignorTest Key: KAFKA-13514 URL: https://issues.apache.org/jira/browse/KAFKA-13514 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-13513) Flaky test AdjustStreamThreadCountTest

Matthias J. Sax created KAFKA-13513: --- Summary: Flaky test AdjustStreamThreadCountTest Key: KAFKA-13513 URL: https://issues.apache.org/jira/browse/KAFKA-13513 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-13490) Fix some problems with KRaft createTopics and incrementalAlterConfigs

[ https://issues.apache.org/jira/browse/KAFKA-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13490: --- Assignee: Colin McCabe (was: Matthias J. Sax) > Fix some problems with KRaft

[jira] [Assigned] (KAFKA-13490) Fix some problems with KRaft createTopics and incrementalAlterConfigs

[ https://issues.apache.org/jira/browse/KAFKA-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13490: --- Assignee: Matthias J. Sax (was: Colin McCabe) > Fix some problems with KRaft

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454227#comment-17454227 ] Matthias J. Sax commented on KAFKA-6995: No. By default it's disabled to send

[jira] [Updated] (KAFKA-13507) GlobalProcessor ignores user specified names

[ https://issues.apache.org/jira/browse/KAFKA-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13507: Labels: beginner newbie (was: ) > GlobalProcessor ignores user specified names >

[jira] [Assigned] (KAFKA-13476) Streams crashes when non Base64 Offset Metadata is found

[ https://issues.apache.org/jira/browse/KAFKA-13476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13476: --- Assignee: Richard Bosch > Streams crashes when non Base64 Offset Metadata is found

[jira] [Commented] (KAFKA-13476) Streams crashes when non Base64 Offset Metadata is found

[ https://issues.apache.org/jira/browse/KAFKA-13476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454154#comment-17454154 ] Matthias J. Sax commented on KAFKA-13476: - [~RBosch81] Thanks for reporting this issue. What I

[jira] [Created] (KAFKA-13507) GlobalProcessor ignored user specified names

Matthias J. Sax created KAFKA-13507: --- Summary: GlobalProcessor ignored user specified names Key: KAFKA-13507 URL: https://issues.apache.org/jira/browse/KAFKA-13507 Project: Kafka Issue

[jira] [Updated] (KAFKA-13507) GlobalProcessor ignores user specified names

[ https://issues.apache.org/jira/browse/KAFKA-13507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13507: Summary: GlobalProcessor ignores user specified names (was: GlobalProcessor ignored user

[jira] [Created] (KAFKA-13501) Avoid state restore via rebalance if standbys are enabled

Matthias J. Sax created KAFKA-13501: --- Summary: Avoid state restore via rebalance if standbys are enabled Key: KAFKA-13501 URL: https://issues.apache.org/jira/browse/KAFKA-13501 Project: Kafka

[jira] [Created] (KAFKA-13500) Consider adding a dedicated standby consumer

Matthias J. Sax created KAFKA-13500: --- Summary: Consider adding a dedicated standby consumer Key: KAFKA-13500 URL: https://issues.apache.org/jira/browse/KAFKA-13500 Project: Kafka Issue

[jira] [Created] (KAFKA-13499) Avoid restoring outdated records

Matthias J. Sax created KAFKA-13499: --- Summary: Avoid restoring outdated records Key: KAFKA-13499 URL: https://issues.apache.org/jira/browse/KAFKA-13499 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-13458) The Stream is not able to consume from some of the partitions

[ https://issues.apache.org/jira/browse/KAFKA-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452111#comment-17452111 ] Matthias J. Sax commented on KAFKA-13458: - [~marathed] You are using the Java consumer directly?

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452038#comment-17452038 ] Matthias J. Sax commented on KAFKA-12377: - And one more. > Flaky Test

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451962#comment-17451962 ] Matthias J. Sax commented on KAFKA-12377: - And one more (different stack trace)

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451961#comment-17451961 ] Matthias J. Sax commented on KAFKA-12377: - Failed again. > Flaky Test

[jira] [Commented] (KAFKA-12377) Flaky Test SaslAuthenticatorTest#testSslClientAuthRequiredForSaslSslListener

[ https://issues.apache.org/jira/browse/KAFKA-12377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451337#comment-17451337 ] Matthias J. Sax commented on KAFKA-12377: - Failed again. > Flaky Test

[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated

[ https://issues.apache.org/jira/browse/KAFKA-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451336#comment-17451336 ] Matthias J. Sax commented on KAFKA-8115: Failed again. > Flaky Test

[jira] [Commented] (KAFKA-13289) Bulk processing correctly ordered input data through a join with kafka-streams results in `Skipping record for expired segment`

[ https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447566#comment-17447566 ] Matthias J. Sax commented on KAFKA-13289: - [~eugendueck] could your issue be related to

[jira] [Commented] (KAFKA-13467) Clients never refresh cached bootstrap IPs

[ https://issues.apache.org/jira/browse/KAFKA-13467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447547#comment-17447547 ] Matthias J. Sax commented on KAFKA-13467: - I am not familiar with the details. [~rsivaram]

[jira] [Resolved] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13405. - Resolution: Not A Bug > Kafka Streams restore-consumer fails to refresh broker IPs

[jira] [Commented] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446605#comment-17446605 ] Matthias J. Sax commented on KAFKA-13405: - Thanks [~rsivaram] – Your explanation aligns to my

[jira] [Created] (KAFKA-13467) Clients never refresh cached bootstrap IPs

Matthias J. Sax created KAFKA-13467: --- Summary: Clients never refresh cached bootstrap IPs Key: KAFKA-13467 URL: https://issues.apache.org/jira/browse/KAFKA-13467 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-13458) The Stream is not able to consume from some of the partitions

[ https://issues.apache.org/jira/browse/KAFKA-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445650#comment-17445650 ] Matthias J. Sax commented on KAFKA-13458: - [~guozhang] – Could it be that there dangling TX that

[jira] [Commented] (KAFKA-13460) Issue reporting

[ https://issues.apache.org/jira/browse/KAFKA-13460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445349#comment-17445349 ] Matthias J. Sax commented on KAFKA-13460: - Kafka uses Jira to track issue. Please create a new

[jira] [Resolved] (KAFKA-13460) Issue reporting

[ https://issues.apache.org/jira/browse/KAFKA-13460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13460. - Resolution: Won't Fix > Issue reporting > --- > > Key:

[jira] [Commented] (KAFKA-13458) The Stream is not able to consume from some of the partitions

[ https://issues.apache.org/jira/browse/KAFKA-13458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445348#comment-17445348 ] Matthias J. Sax commented on KAFKA-13458: - Seems you are using exactly-once? I assume there are

[jira] [Commented] (KAFKA-8541) Flakey test LeaderElectionCommandTest#testTopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438217#comment-17438217 ] Matthias J. Sax commented on KAFKA-8541: Failed again (different test) {code:java}

[jira] [Updated] (KAFKA-13426) Add recordMetadata to StateStoreContext

[ https://issues.apache.org/jira/browse/KAFKA-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13426: Labels: kip (was: ) > Add recordMetadata to StateStoreContext >

[jira] [Updated] (KAFKA-13426) Add recordMetadata to StateStoreContext

[ https://issues.apache.org/jira/browse/KAFKA-13426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13426: Description: KIP-791:

[jira] [Commented] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437108#comment-17437108 ] Matthias J. Sax commented on KAFKA-13351: - Fixed: added you to the list of contributors. You can

[jira] [Comment Edited] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437108#comment-17437108 ] Matthias J. Sax edited comment on KAFKA-13351 at 11/2/21, 2:35 AM: ---

[jira] [Updated] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13351: Component/s: tools > Add possibility to write kafka headers in Kafka Console Producer >

[jira] [Assigned] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

[ https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13351: --- Assignee: Florin Akermann > Add possibility to write kafka headers in Kafka

[jira] [Commented] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437090#comment-17437090 ] Matthias J. Sax commented on KAFKA-13405: - I am not 100% sure about the detail how producer and

[jira] [Assigned] (KAFKA-13423) Error falsely reported on Kafka Streams app when GlobalKTables are used

[ https://issues.apache.org/jira/browse/KAFKA-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13423: --- Assignee: Matthias J. Sax > Error falsely reported on Kafka Streams app when

[jira] [Commented] (KAFKA-13400) offset() is not supported in standby tasks.

[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435676#comment-17435676 ] Matthias J. Sax commented on KAFKA-13400: - [~pbiradar] Could you share the code of

[jira] [Commented] (KAFKA-13400) offset() is not supported in standby tasks.

[ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435214#comment-17435214 ] Matthias J. Sax commented on KAFKA-13400: - [~grussell] – thanks for chiming in! – I agree that

[jira] [Updated] (KAFKA-13412) Retry of initTransactions after timeout may cause invalid transition

[ https://issues.apache.org/jira/browse/KAFKA-13412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13412: Component/s: producer > Retry of initTransactions after timeout may cause invalid

[jira] [Commented] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435163#comment-17435163 ] Matthias J. Sax commented on KAFKA-13405: - Thanks for reporting this issue. {quote} * None of

[jira] [Comment Edited] (KAFKA-13405) Kafka Streams restore-consumer fails to refresh broker IPs after upgrading Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435163#comment-17435163 ] Matthias J. Sax edited comment on KAFKA-13405 at 10/28/21, 5:39 AM:

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434066#comment-17434066 ] Matthias J. Sax commented on KAFKA-12960: - Yes, but if we move the check into MeteredXxxStore we

[jira] [Commented] (KAFKA-12960) WindowStore and SessionStore do not enforce strict retention time

[ https://issues.apache.org/jira/browse/KAFKA-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433856#comment-17433856 ] Matthias J. Sax commented on KAFKA-12960: - I just got a report, that `InMemoryWindowStore` does

[jira] [Commented] (KAFKA-10493) KTable out-of-order updates are not being ignored

[ https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433123#comment-17433123 ] Matthias J. Sax commented on KAFKA-10493: - A custom timestamp extractor seems orthogonal. – Even

[jira] [Commented] (KAFKA-13373) ValueTransformerWithKeySupplier doesn't work with store()

[ https://issues.apache.org/jira/browse/KAFKA-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430650#comment-17430650 ] Matthias J. Sax commented on KAFKA-13373: - I did not look into it too deeply, but I guess it

[jira] [Updated] (KAFKA-13381) Wrap all uncaught exceptions as StreamsException with TaskId field

[ https://issues.apache.org/jira/browse/KAFKA-13381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13381: Labels: kip (was: needs-kip) > Wrap all uncaught exceptions as StreamsException with

[jira] [Updated] (KAFKA-13381) Wrap all uncaught exceptions as StreamsException with TaskId field

[ https://issues.apache.org/jira/browse/KAFKA-13381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13381: Description: KIP-783:

[jira] [Commented] (KAFKA-13377) Fix Resocue leak due to Files.list

[ https://issues.apache.org/jira/browse/KAFKA-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429373#comment-17429373 ] Matthias J. Sax commented on KAFKA-13377: - Thanks for reporting and fixing! Added you to the

[jira] [Assigned] (KAFKA-13377) Fix Resocue leak due to Files.list

[ https://issues.apache.org/jira/browse/KAFKA-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13377: --- Assignee: lujie > Fix Resocue leak due to Files.list >

[jira] [Resolved] (KAFKA-13377) Fix Resocue leak due to Files.list

[ https://issues.apache.org/jira/browse/KAFKA-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13377. - Fix Version/s: 3.1.0 Resolution: Fixed > Fix Resocue leak due to Files.list >

[jira] [Commented] (KAFKA-8785) Flakey test LeaderElectionCommandTest#testPathToJsonFile

[ https://issues.apache.org/jira/browse/KAFKA-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429370#comment-17429370 ] Matthias J. Sax commented on KAFKA-8785: Observed another timeout (different test): {code:java}

[jira] [Updated] (KAFKA-13375) Kafka streams apps w/EOS unable to start at InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-13375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13375: Component/s: streams > Kafka streams apps w/EOS unable to start at InitProducerId >

[jira] [Updated] (KAFKA-12909) Allow users to opt-into spurious left/outer stream-stream join improvement

[ https://issues.apache.org/jira/browse/KAFKA-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-12909: Fix Version/s: (was: 3.0.0) 3.1.0 > Allow users to opt-into

[jira] [Updated] (KAFKA-8613) Make Grace Period Mandatory for Windowed Operations in Streams

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8613: --- Fix Version/s: 3.1.0 > Make Grace Period Mandatory for Windowed Operations in Streams >

[jira] [Commented] (KAFKA-13364) SQL Processor Alerts Creation when Failed

[ https://issues.apache.org/jira/browse/KAFKA-13364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428318#comment-17428318 ] Matthias J. Sax commented on KAFKA-13364: - Not sure if I understand this request. Also, what do

[jira] [Updated] (KAFKA-13364) SQL Processor Alerts Creation when Failed

[ https://issues.apache.org/jira/browse/KAFKA-13364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13364: Fix Version/s: (was: 2.5.1) (was: 3.0.0) > SQL Processor

[jira] [Commented] (KAFKA-13024) Kafka Streams is dropping messages with null key during repartition

[ https://issues.apache.org/jira/browse/KAFKA-13024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427868#comment-17427868 ] Matthias J. Sax commented on KAFKA-13024: - While I think `repartition()` has indeed a regression

[jira] [Resolved] (KAFKA-13356) Use "delete" retention policy only for stream-stream join windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-13356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13356. - Resolution: Duplicate > Use "delete" retention policy only for stream-stream join

[jira] [Assigned] (KAFKA-13356) Use "delete" retention policy only for stream-stream join windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-13356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13356: --- Assignee: Matthias J. Sax > Use "delete" retention policy only for stream-stream

[jira] [Updated] (KAFKA-13350) Handle task corrupted exception on a per state store basis

[ https://issues.apache.org/jira/browse/KAFKA-13350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13350: Description: When we hit an `OffsetOutOfRangeException` during restore, we close a tasks

[jira] [Created] (KAFKA-13350) Handle task corrupted exception on a per state store basis

Matthias J. Sax created KAFKA-13350: --- Summary: Handle task corrupted exception on a per state store basis Key: KAFKA-13350 URL: https://issues.apache.org/jira/browse/KAFKA-13350 Project: Kafka

[jira] [Updated] (KAFKA-13349) Allow Iterator.remove on KeyValueIterator

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

[jira] [Updated] (KAFKA-13346) Kafka Streams fails due to RocksDB Locks Not Available Exception

[ https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13346: Component/s: streams > Kafka Streams fails due to RocksDB Locks Not Available Exception >

[jira] [Updated] (KAFKA-13339) Kstream not fetch all the messages

[ https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13339: Component/s: (was: consumer) streams > Kstream not fetch all the

[jira] [Resolved] (KAFKA-13339) Kstream not fetch all the messages

[ https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13339. - Resolution: Invalid > Kstream not fetch all the messages >

[jira] [Commented] (KAFKA-13339) Kstream not fetch all the messages

[ https://issues.apache.org/jira/browse/KAFKA-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424304#comment-17424304 ] Matthias J. Sax commented on KAFKA-13339: - The logs you shared don't contain any errors... It's

[jira] [Commented] (KAFKA-13326) Add multi-cluster support to Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424298#comment-17424298 ] Matthias J. Sax commented on KAFKA-13326: - Neither mirror-maker2 not replicator support EOS

[jira] [Assigned] (KAFKA-13345) WindowStore should use "delete" policy when duplicates are enabled

[ https://issues.apache.org/jira/browse/KAFKA-13345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13345: --- Assignee: Matthias J. Sax > WindowStore should use "delete" policy when duplicates

<    4   5   6   7   8   9   10   11   12   13   >