[jira] [Comment Edited] (KAFKA-7575) 'Error while writing to checkpoint file' Issue

[ https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478378#comment-17478378 ] Jacek edited comment on KAFKA-7575 at 1/19/22, 7:55 AM: kafka cannot be used on

[jira] [Commented] (KAFKA-7575) 'Error while writing to checkpoint file' Issue

[ https://issues.apache.org/jira/browse/KAFKA-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478378#comment-17478378 ] Jacek commented on KAFKA-7575: -- {code} [2022-01-19 08:36:40,392] ERROR Disk error while writing recovery

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787413882 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java ## @@ -514,11 +509,12 @@ public ProducerConfig(Map props) {

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787412220 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java ## @@ -456,33 +455,29 @@ private void

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787411447 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java ## @@ -456,33 +455,29 @@ private void

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787411203 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java ## @@ -456,33 +455,29 @@ private void

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787410613 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java ## @@ -540,28 +534,6 @@ private TransactionManager

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787409706 ## File path: clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java ## @@ -511,15 +512,8 @@ private static int

[GitHub] [kafka] showuon commented on a change in pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon commented on a change in pull request #11691: URL: https://github.com/apache/kafka/pull/11691#discussion_r787408812 ## File path: clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java ## @@ -194,8 +194,8 @@ public static Map

[GitHub] [kafka] showuon opened a new pull request #11691: KAFKA-13598: enable and validate config for idempotence producer

showuon opened a new pull request #11691: URL: https://github.com/apache/kafka/pull/11691 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade

[jira] [Commented] (KAFKA-13596) ERROR Error while deleting segments for {topic} : java.nio.file.NoSuchFileException

[ https://issues.apache.org/jira/browse/KAFKA-13596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478321#comment-17478321 ] 小小小杰 commented on KAFKA-13596: -- It appears by itself and no stable way of recurrence has been found

[jira] [Commented] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478308#comment-17478308 ] Luke Chen commented on KAFKA-13598: --- Since the memory leak issue: KAFKA-13597 is confirmed to be a bad

[jira] [Updated] (KAFKA-13600) Rebalances while streams is in degraded state can cause stores to be reassigned and restore from scratch

[ https://issues.apache.org/jira/browse/KAFKA-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim Patterson updated KAFKA-13600: -- Summary: Rebalances while streams is in degraded state can cause stores to be reassigned and

[jira] [Commented] (KAFKA-10121) Streams Task Assignment optimization design

[ https://issues.apache.org/jira/browse/KAFKA-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478283#comment-17478283 ] Tim Patterson commented on KAFKA-10121: --- Created https://issues.apache.org/jira/browse/KAFKA-13600

[jira] [Created] (KAFKA-13600) Rebalances while streams is in degraded state can stores to be assigned and restore from scratch

Tim Patterson created KAFKA-13600: - Summary: Rebalances while streams is in degraded state can stores to be assigned and restore from scratch Key: KAFKA-13600 URL:

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478270#comment-17478270 ] Luke Chen commented on KAFKA-13597: --- Good to hear that! Thank you for following up! > Memory leak

[GitHub] [kafka] tim-patterson commented on pull request #11493: KAFKA-12959: Prioritise assigning standby tasks to threads without any active tasks

tim-patterson commented on pull request #11493: URL: https://github.com/apache/kafka/pull/11493#issuecomment-1015895827 Hey @ableegoldman I see you've got a few commits on this file, Would you be able to review or point us in the direction of one of your co-committers who might be able to

[GitHub] [kafka] vvcephei commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vvcephei commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r787180989 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java ## @@ -148,8 +150,12 @@ default void init(final

[jira] [Resolved] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Willian Dallastella resolved KAFKA-13597. - Resolution: Not A Problem > Memory leak with kafka-clients 3.0.0 >

[GitHub] [kafka] jonathan-albrecht-ibm opened a new pull request #11690: KAFKA-13599: Upgrade RocksDB to 6.27.3

jonathan-albrecht-ibm opened a new pull request #11690: URL: https://github.com/apache/kafka/pull/11690 RocksDB v6.27.3 has been released and it is the first release to support s390x. RocksDB is currently the only dependency in gradle/dependencies.gradle without s390x support.

[GitHub] [kafka] ableegoldman merged pull request #11600: KAFKA-12648: handle MissingSourceTopicException for named topologies

ableegoldman merged pull request #11600: URL: https://github.com/apache/kafka/pull/11600 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] ableegoldman commented on pull request #11600: KAFKA-12648: handle MissingSourceTopicException for named topologies

ableegoldman commented on pull request #11600: URL: https://github.com/apache/kafka/pull/11600#issuecomment-1015777307 Test failures are unrelated, will address @cadonna 's remaining feedback in the followup PR https://github.com/apache/kafka/pull/11686 -- going to merge failures:

[GitHub] [kafka] dajac closed pull request #11559: KAFKA-13435; Group won't consume partitions added after static member restart

dajac closed pull request #11559: URL: https://github.com/apache/kafka/pull/11559 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] philipnee opened a new pull request #11689: KAFKA-12841 patch

philipnee opened a new pull request #11689: URL: https://github.com/apache/kafka/pull/11689 Jira: https://issues.apache.org/jira/browse/KAFKA-12841 Using the `InterceptorCallback` wrapper in the case of `ApiException` so that we will adhere correctly to the `Callback` contract for

[jira] [Commented] (KAFKA-10245) Using vulnerable log4j version

[ https://issues.apache.org/jira/browse/KAFKA-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478121#comment-17478121 ] Warren Grunbok commented on KAFKA-10245: expected would be log4j 2.17 or higher, not 2.13 >

[GitHub] [kafka] rondagostino commented on a change in pull request #11606: MINOR: Add shutdown tests for KRaft

rondagostino commented on a change in pull request #11606: URL: https://github.com/apache/kafka/pull/11606#discussion_r787045338 ## File path: core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala ## @@ -253,4 +248,32 @@ abstract class KafkaServerTestHarness

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

[ https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478116#comment-17478116 ] Warren Grunbok commented on KAFKA-9366: --- I'm also looking for an official release date with the

[GitHub] [kafka] cmccabe commented on a change in pull request #11606: MINOR: Add shutdown tests for KRaft

cmccabe commented on a change in pull request #11606: URL: https://github.com/apache/kafka/pull/11606#discussion_r787027731 ## File path: core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala ## @@ -253,4 +248,32 @@ abstract class KafkaServerTestHarness

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r786517360 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, }

[jira] [Comment Edited] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478086#comment-17478086 ] David Jacot edited comment on KAFKA-13598 at 1/18/22, 5:55 PM: --- That seems

[jira] [Commented] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478086#comment-17478086 ] David Jacot commented on KAFKA-13598: - That seems to be a bug and not a regression introduced in 3.1

[jira] [Assigned] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Albrecht reassigned KAFKA-13599: - Assignee: Jonathan Albrecht > Upgrade RocksDB to 6.27.3 >

[jira] [Commented] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478049#comment-17478049 ] Jonathan Albrecht commented on KAFKA-13599: --- Hi [~cadonna], Yes, I'm testing a PR right now.

[GitHub] [kafka] vvcephei commented on a change in pull request #11676: feat: checkpoint position in state stores

vvcephei commented on a change in pull request #11676: URL: https://github.com/apache/kafka/pull/11676#discussion_r786893179 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java ## @@ -94,7 +94,8 @@ * @throws StreamsException if

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478036#comment-17478036 ] Ismael Juma commented on KAFKA-13597: - Makes sense to close then. Thanks for following up! > Memory

[jira] [Updated] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13597: Fix Version/s: (was: 3.0.1) > Memory leak with kafka-clients 3.0.0 >

[GitHub] [kafka] dajac opened a new pull request #11688: KAFKA-13435; Group won't consume partitions added after static member restart

dajac opened a new pull request #11688: URL: https://github.com/apache/kafka/pull/11688 WIP/Require a KIP. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation

[jira] [Created] (KAFKA-13599) Upgrade RocksDB to 6.27.3

Jonathan Albrecht created KAFKA-13599: - Summary: Upgrade RocksDB to 6.27.3 Key: KAFKA-13599 URL: https://issues.apache.org/jira/browse/KAFKA-13599 Project: Kafka Issue Type: Task

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477981#comment-17477981 ] Willian Dallastella edited comment on KAFKA-13597 at 1/18/22, 3:42 PM:

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477981#comment-17477981 ] Willian Dallastella edited comment on KAFKA-13597 at 1/18/22, 3:40 PM:

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477981#comment-17477981 ] Willian Dallastella edited comment on KAFKA-13597 at 1/18/22, 3:38 PM:

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477981#comment-17477981 ] Willian Dallastella edited comment on KAFKA-13597 at 1/18/22, 3:37 PM:

[jira] [Comment Edited] (KAFKA-10413) rebalancing leads to unevenly balanced connectors

[ https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477980#comment-17477980 ] yazgoo edited comment on KAFKA-10413 at 1/18/22, 3:35 PM: -- Hi, any news on this

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477981#comment-17477981 ] Willian Dallastella commented on KAFKA-13597: - Hey [~showuon], so I changed the service

[jira] [Commented] (KAFKA-10413) rebalancing leads to unevenly balanced connectors

[ https://issues.apache.org/jira/browse/KAFKA-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477980#comment-17477980 ] yazgoo commented on KAFKA-10413: Hi, any news on this issue ? I'm suspecting it is linked with

[jira] [Commented] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477963#comment-17477963 ] Ismael Juma commented on KAFKA-13598: - [~showuon] it would be good to determine if this is a 3.1.0

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477964#comment-17477964 ] Ismael Juma commented on KAFKA-13597: - [~showuon] it would be good to determine if this is a 3.1.0

[jira] [Updated] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13598: Fix Version/s: 3.0.1 > producer config didn't throw exception when retries and acks config

[jira] [Updated] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-13597: Fix Version/s: 3.0.1 > Memory leak with kafka-clients 3.0.0 >

[GitHub] [kafka] vpapavas commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vpapavas commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786849830 ## File path: streams/src/main/java/org/apache/kafka/streams/query/QueryConfig.java ## @@ -0,0 +1,35 @@ +/* + * Licensed to the Apache Software

[GitHub] [kafka] vpapavas commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vpapavas commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786669972 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java ## @@ -152,4 +153,8 @@ default void init(final StateStoreContext

[GitHub] [kafka] vpapavas commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vpapavas commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786848574 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java ## @@ -148,8 +150,12 @@ default void init(final

[GitHub] [kafka] C0urante commented on pull request #11333: KAFKA-13306: Null connector config value passes validation, but fails creation

C0urante commented on pull request #11333: URL: https://github.com/apache/kafka/pull/11333#issuecomment-1015468012 @tombentley @kkonstantine would either of you have time for this small but valuable fix? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (KAFKA-13596) ERROR Error while deleting segments for {topic} : java.nio.file.NoSuchFileException

[ https://issues.apache.org/jira/browse/KAFKA-13596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477918#comment-17477918 ] Kvicii.Yu commented on KAFKA-13596: --- [~shiyc]  Could you tell me how can I reproduce this problem >

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477865#comment-17477865 ] Luke Chen commented on KAFKA-13597: --- That's great! Thanks [~willian.wd] ! > Memory leak with

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477862#comment-17477862 ] Willian Dallastella commented on KAFKA-13597: - I'll test it and let you know. > Memory leak

[jira] [Updated] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-13598: -- Description: In KAFKA-10619, we enabled idempotence by default. But we didn't update the config

[jira] [Commented] (KAFKA-13581) Error getting old protocol

[ https://issues.apache.org/jira/browse/KAFKA-13581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477859#comment-17477859 ] Kvicii.Yu commented on KAFKA-13581: --- [~chenzy] thanks for your reporting. In fact, I agree with this

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477843#comment-17477843 ] Luke Chen commented on KAFKA-13597: --- Sorry, I found for the 1st option, you need to explicitly add

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477709#comment-17477709 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 1:13 PM: - [~dajac]

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477785#comment-17477785 ] Luke Chen edited comment on KAFKA-13597 at 1/18/22, 1:12 PM: - Also, if

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477785#comment-17477785 ] Luke Chen edited comment on KAFKA-13597 at 1/18/22, 1:12 PM: - Also, if

[jira] [Comment Edited] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477678#comment-17477678 ] Luke Chen edited comment on KAFKA-13597 at 1/18/22, 1:12 PM: - [~willian.wd]

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477709#comment-17477709 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 1:11 PM: - [~dajac]

[GitHub] [kafka] satishd commented on pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on pull request #11390: URL: https://github.com/apache/kafka/pull/11390#issuecomment-1015392509 @junrao Thanks for the review. Please find inline replies, updated the PR addressing them with the latest commits. -- This is an automated message from the Apache Git

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r786736586 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, }

[GitHub] [kafka] cadonna commented on a change in pull request #11600: KAFKA-12648: handle MissingSourceTopicException for named topologies

cadonna commented on a change in pull request #11600: URL: https://github.com/apache/kafka/pull/11600#discussion_r786702599 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/RepartitionTopicsTest.java ## @@ -162,14 +169,17 @@ public void

[GitHub] [kafka] patrickstuedi commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

patrickstuedi commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786686638 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java ## @@ -83,10 +89,64 @@ public void

[GitHub] [kafka] vpapavas commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vpapavas commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786672285 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java ## @@ -78,7 +78,7 @@ public

[GitHub] [kafka] vpapavas commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vpapavas commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786669972 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java ## @@ -152,4 +153,8 @@ default void init(final StateStoreContext

[GitHub] [kafka] vpapavas commented on a change in pull request #11682: feat: Add IQv2 query handling to the caching layer

vpapavas commented on a change in pull request #11682: URL: https://github.com/apache/kafka/pull/11682#discussion_r786669591 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java ## @@ -83,10 +89,64 @@ public void init(final

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477785#comment-17477785 ] Luke Chen commented on KAFKA-13597: --- Also, if removing the `ack` config doesn't fix the issue (which I

[GitHub] [kafka] nicktelford commented on pull request #11610: KAFKA-13549: Add min.repartition.purge.interval.ms

nicktelford commented on pull request #11610: URL: https://github.com/apache/kafka/pull/11610#issuecomment-1015328560 @mjsax The KIP has now been adopted and I've updated this PR to reflect the latest version of the KIP. Should now be ready for review. -- This is an automated message

[GitHub] [kafka] nicktelford edited a comment on pull request #11610: KAFKA-13549: Add min.repartition.purge.interval.ms

nicktelford edited a comment on pull request #11610: URL: https://github.com/apache/kafka/pull/11610#issuecomment-1010106545 KIP available at: https://cwiki.apache.org/confluence/display/KAFKA/KIP-811%3A+Add+config+repartition.purge.interval.ms+to+Kafka+Streams The commit and PR

[jira] [Comment Edited] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477709#comment-17477709 ] Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 11:09 AM: -- [~dajac]

[GitHub] [kafka] Kvicii opened a new pull request #11687: Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

Kvicii opened a new pull request #11687: URL: https://github.com/apache/kafka/pull/11687 this issue similar to https://github.com/apache/kafka/pull/11666. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage

[GitHub] [kafka] lhunyady commented on pull request #11333: KAFKA-13306: Null connector config value passes validation, but fails creation

lhunyady commented on pull request #11333: URL: https://github.com/apache/kafka/pull/11333#issuecomment-1015284006 @C0urante what are the next steps to get this pull request merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Assigned] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kvicii.Yu reassigned KAFKA-13592: - Assignee: Kvicii.Yu > Fix flaky test >

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477709#comment-17477709 ] Kvicii.Yu commented on KAFKA-13592: --- [~dajac] thanks a lot.bro > Fix flaky test >

[jira] [Updated] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

[ https://issues.apache.org/jira/browse/KAFKA-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen updated KAFKA-13598: -- Description: In KAFKA-10619, we enabled idempotence by default. But we didn't update the config

[jira] [Commented] (KAFKA-13597) Memory leak with kafka-clients 3.0.0

[ https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477678#comment-17477678 ] Luke Chen commented on KAFKA-13597: --- [~willian.wd] , there is a config *ack* set to 1, are you meaning

[jira] [Created] (KAFKA-13598) producer config didn't throw exception when retries and acks config changed

Luke Chen created KAFKA-13598: - Summary: producer config didn't throw exception when retries and acks config changed Key: KAFKA-13598 URL: https://issues.apache.org/jira/browse/KAFKA-13598 Project: Kafka

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r786518882 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -715,6 +727,58 @@ abstract class AbstractFetcherThread(name: String,

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r784817355 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -715,6 +727,58 @@ abstract class AbstractFetcherThread(name: String,

[GitHub] [kafka] satishd commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

satishd commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r786517360 ## File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala ## @@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String, }

[jira] [Commented] (KAFKA-13592) Fix flaky test ControllerIntegrationTest.testTopicIdUpgradeAfterReassigningPartitions

[ https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477657#comment-17477657 ] David Jacot commented on KAFKA-13592: - [~Kvicii] I don't know the reason of this issue... However, I