[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Summary: The topic is marked for deletion, create topic with the same name throw exception topic

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Description: After a topic is deleted, the topic is marked for deletion, create topic with the

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: fff.jpg > The topic is marked for deletion, create topic with the same name throw >

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: (was: fff.jpg) > The topic is marked for deletion, create topic with the same na

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: zookeeper.jpg kafka (2).jpg > The topic is marked for deletion, crea

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: kafka (2).jpg > The topic is marked for deletion, create topic with the same name th

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: (was: kafka (2).jpg) > The topic is marked for deletion, create topic with the s

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: (was: zookeeper.jpg) > The topic is marked for deletion, create topic with the s

[jira] [Updated] (KAFKA-13175) The topic is marked for deletion, create topic with the same name throw exception topic already exists.

[ https://issues.apache.org/jira/browse/KAFKA-13175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yangshengwei updated KAFKA-13175: - Attachment: zookeeper.jpg > The topic is marked for deletion, create topic with the same name th

[GitHub] [kafka] yangdaixai closed pull request #11185: KAFKA-13175; Better indicates for created topic is marked for deleti…

yangdaixai closed pull request #11185: URL: https://github.com/apache/kafka/pull/11185 -- 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: jira-unsubs

[jira] [Created] (KAFKA-13211) fetch queries with open endpoints for WindowStore

Luke Chen created KAFKA-13211: - Summary: fetch queries with open endpoints for WindowStore Key: KAFKA-13211 URL: https://issues.apache.org/jira/browse/KAFKA-13211 Project: Kafka Issue Type: Sub-t

[jira] [Created] (KAFKA-13212) findSessions queries with open endpoints for SessionStore

Luke Chen created KAFKA-13212: - Summary: findSessions queries with open endpoints for SessionStore Key: KAFKA-13212 URL: https://issues.apache.org/jira/browse/KAFKA-13212 Project: Kafka Issue Typ

[GitHub] [kafka] dajac commented on a change in pull request #11170: KAFKA-13102: Topic IDs not propagated to metadata cache quickly enough for Fetch path

dajac commented on a change in pull request #11170: URL: https://github.com/apache/kafka/pull/11170#discussion_r690993461 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig, partitionsT

[GitHub] [kafka] dajac opened a new pull request #11225: MINOR; Small optimizations in `ReplicaManager#becomeLeaderOrFollower`

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

[GitHub] [kafka] yangdaixai opened a new pull request #11226: KAFKA-13175; Optimization TopicExistsException,When a topic is marked…

yangdaixai opened a new pull request #11226: URL: https://github.com/apache/kafka/pull/11226 … for deletion. After a topic is deleted, the topic is marked for deletion, create topic with the same name throw exception topic already exists. It should throw exception the topic is marke

[GitHub] [kafka] dajac commented on a change in pull request #11225: MINOR; Small optimizations in `ReplicaManager#becomeLeaderOrFollower`

dajac commented on a change in pull request #11225: URL: https://github.com/apache/kafka/pull/11225#discussion_r691041467 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig, le

[GitHub] [kafka] showuon opened a new pull request #11227: KAFKA-13211: add support for infinite range query for WindowStore

showuon opened a new pull request #11227: URL: https://github.com/apache/kafka/pull/11227 Add support for infinite range query for WindowStore. Story JIRA: https://issues.apache.org/jira/browse/KAFKA-13210 ### Committer Checklist (excluded from commit message) - [ ] Verify d

[GitHub] [kafka] showuon commented on a change in pull request #11227: KAFKA-13211: add support for infinite range query for WindowStore

showuon commented on a change in pull request #11227: URL: https://github.com/apache/kafka/pull/11227#discussion_r691052026 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java ## @@ -124,8 +124,8 @@ fi

[GitHub] [kafka] showuon commented on a change in pull request #11227: KAFKA-13211: add support for infinite range query for WindowStore

showuon commented on a change in pull request #11227: URL: https://github.com/apache/kafka/pull/11227#discussion_r691053240 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java ## @@ -573,12 +573,14 @@ private void setCacheKeyRan

[GitHub] [kafka] showuon commented on a change in pull request #11227: KAFKA-13211: add support for infinite range query for WindowStore

showuon commented on a change in pull request #11227: URL: https://github.com/apache/kafka/pull/11227#discussion_r691055719 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java ## @@ -74,7 +74,7 @@ public boolean hasNext() {

[GitHub] [kafka] dajac commented on pull request #11073: KAFKA-13092: Perf regression in LISR requests

dajac commented on pull request #11073: URL: https://github.com/apache/kafka/pull/11073#issuecomment-901015825 @jolshan is it something that we must add to 2.8.1? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [kafka] jlprat opened a new pull request #11228: KAFKA-12887 Skip some RuntimeExceptions from exception handler

jlprat opened a new pull request #11228: URL: https://github.com/apache/kafka/pull/11228 Instead of letting all `RuntimeException`s go through and be processed by the uncaught exception handler, `IllegalStateException` and `IllegalArgumentException` are not passed through and fail fast

[GitHub] [kafka] jlprat commented on pull request #11228: KAFKA-12887 Skip some RuntimeExceptions from exception handler

jlprat commented on pull request #11228: URL: https://github.com/apache/kafka/pull/11228#issuecomment-901030641 cc. @guozhangwang Feel free to review this PR and let me know if this is what you had in mind with https://issues.apache.org/jira/browse/KAFKA-12887 -- This is an automated mes

[GitHub] [kafka] dajac opened a new pull request #11229: KAFKA-12961; Verify group generation in `DelayedJoin`

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

[jira] [Created] (KAFKA-13213) StreamThread: State transition from PARTITIONS_ASSIGNED to PARTITIONS_ASSIGNED

Patrik Kleindl created KAFKA-13213: -- Summary: StreamThread: State transition from PARTITIONS_ASSIGNED to PARTITIONS_ASSIGNED Key: KAFKA-13213 URL: https://issues.apache.org/jira/browse/KAFKA-13213 Pr

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401034#comment-17401034 ] Sagar Rao commented on KAFKA-13152: --- [~mjsax], [~guozhang] I had a slightly different

[jira] [Commented] (KAFKA-8295) Add merge() operator to State Stores.

[ https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401043#comment-17401043 ] Sagar Rao commented on KAFKA-8295: -- I see. Is there a KIP for list append types for wind

[jira] [Reopened] (KAFKA-8529) Flakey test ConsumerBounceTest#testCloseDuringRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Josep Prat reopened KAFKA-8529: --- > Flakey test ConsumerBounceTest#testCloseDuringRebalance > -

[jira] [Commented] (KAFKA-8529) Flakey test ConsumerBounceTest#testCloseDuringRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401062#comment-17401062 ] Josep Prat commented on KAFKA-8529: --- I'll reopen this issue as it happened again on a f

[GitHub] [kafka] jomach commented on pull request #9493: KAFKA-10640: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSO

jomach commented on pull request #9493: URL: https://github.com/apache/kafka/pull/9493#issuecomment-901121979 seems to be some conflicts. @joshuagrisham can you fix them please ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [kafka] jlprat commented on pull request #11228: KAFKA-12887 Skip some RuntimeExceptions from exception handler

jlprat commented on pull request #11228: URL: https://github.com/apache/kafka/pull/11228#issuecomment-901123276 Test failure was https://issues.apache.org/jira/browse/KAFKA-8529 which was apparently resolved. I reopened the issue. I rebased this PR to the trunk of a couple of hours ago.

[GitHub] [kafka] cadonna commented on a change in pull request #11149: KIP-761: add total blocked time metric to streams

cadonna commented on a change in pull request #11149: URL: https://github.com/apache/kafka/pull/11149#discussion_r691098389 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java ## @@ -0,0 +1,59 @@ +/* + * Licensed

[GitHub] [kafka] dajac opened a new pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

dajac opened a new pull request #11230: URL: https://github.com/apache/kafka/pull/11230 When `compact` is removed from the `cleanup.policy` of a topic, the compactions of that topic should be aborted. ### Committer Checklist (excluded from commit message) - [ ] Verify design and i

[GitHub] [kafka] jolshan commented on a change in pull request #11170: KAFKA-13102: Topic IDs not propagated to metadata cache quickly enough for Fetch path

jolshan commented on a change in pull request #11170: URL: https://github.com/apache/kafka/pull/11170#discussion_r691366479 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig, partition

[GitHub] [kafka] lbradstreet commented on a change in pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

lbradstreet commented on a change in pull request #11230: URL: https://github.com/apache/kafka/pull/11230#discussion_r691368381 ## File path: core/src/main/scala/kafka/server/ConfigHandler.scala ## @@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,

[GitHub] [kafka] jolshan commented on pull request #11073: KAFKA-13092: Perf regression in LISR requests

jolshan commented on pull request #11073: URL: https://github.com/apache/kafka/pull/11073#issuecomment-901220052 Ah yes. I had a feeling I still had a pr open for this. I think I can clean it up a bit and it should be ready for review by tomorrow. -- This is an automated message from the

[GitHub] [kafka] dajac commented on a change in pull request #11173: MINOR: Support max timestamp in GetOffsetShell

dajac commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r691375264 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -224,9 +227,14 @@ object GetOffsetShell { /** * Return the partition infos.

[GitHub] [kafka] dajac commented on a change in pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

dajac commented on a change in pull request #11230: URL: https://github.com/apache/kafka/pull/11230#discussion_r691396770 ## File path: core/src/main/scala/kafka/server/ConfigHandler.scala ## @@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager, kafka

[GitHub] [kafka] dajac commented on a change in pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

dajac commented on a change in pull request #11230: URL: https://github.com/apache/kafka/pull/11230#discussion_r691400434 ## File path: core/src/main/scala/kafka/server/ConfigHandler.scala ## @@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager, kafka

[jira] [Created] (KAFKA-13214) Consumer should not reset group state after disconnect

Jason Gustafson created KAFKA-13214: --- Summary: Consumer should not reset group state after disconnect Key: KAFKA-13214 URL: https://issues.apache.org/jira/browse/KAFKA-13214 Project: Kafka

[GitHub] [kafka] dajac commented on a change in pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

dajac commented on a change in pull request #11230: URL: https://github.com/apache/kafka/pull/11230#discussion_r691396770 ## File path: core/src/main/scala/kafka/server/ConfigHandler.scala ## @@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager, kafka

[GitHub] [kafka] dajac commented on a change in pull request #11173: MINOR: Support max timestamp in GetOffsetShell

dajac commented on a change in pull request #11173: URL: https://github.com/apache/kafka/pull/11173#discussion_r691375264 ## File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala ## @@ -224,9 +227,14 @@ object GetOffsetShell { /** * Return the partition infos.

[GitHub] [kafka] venkatesh010 commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

venkatesh010 commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900514731 -- 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 unsub

[GitHub] [kafka] jolshan commented on a change in pull request #11170: KAFKA-13102: Topic IDs not propagated to metadata cache quickly enough for Fetch path

jolshan commented on a change in pull request #11170: URL: https://github.com/apache/kafka/pull/11170#discussion_r691366479 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig, partition

[GitHub] [kafka] rondagostino commented on pull request #6233: KAFKA-7902: Replace original loginContext if SASL/OAUTHBEARER refresh login fails

rondagostino commented on pull request #6233: URL: https://github.com/apache/kafka/pull/6233#issuecomment-900456795 -- 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 unsub

[jira] [Updated] (KAFKA-13215) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation

[ https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-13215: --- Reporter: Konstantine Karantasis (was: Bruno Cadonna) > Flaky test > org.a

[jira] [Created] (KAFKA-13215) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation

Konstantine Karantasis created KAFKA-13215: -- Summary: Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation Key: KAFKA-13215 URL: https://issu

[jira] [Assigned] (KAFKA-13215) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation

[ https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis reassigned KAFKA-13215: -- Assignee: (was: Walker Carlson) > Flaky test > org.apache.kafka.

[GitHub] [kafka] dajac commented on a change in pull request #11170: KAFKA-13102: Topic IDs not propagated to metadata cache quickly enough for Fetch path

dajac commented on a change in pull request #11170: URL: https://github.com/apache/kafka/pull/11170#discussion_r690993461 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1755,6 +1765,78 @@ class ReplicaManager(val config: KafkaConfig, partitionsT

[GitHub] [kafka] omkreddy merged pull request #11224: KAFKA-13209: Upgrade jetty-server to fix CVE-2021-34429

omkreddy merged pull request #11224: URL: https://github.com/apache/kafka/pull/11224 -- 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: jira-unsubscr

[jira] [Updated] (KAFKA-13215) Flaky test org.apache.kafka.streams.integration.TaskMetadataIntegrationTest.shouldReportCorrectEndOffsetInformation

[ https://issues.apache.org/jira/browse/KAFKA-13215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-13215: --- Description: Integration test {{test org.apache.kafka.streams.integration.T

[GitHub] [kafka] cadonna commented on a change in pull request #11149: KIP-761: add total blocked time metric to streams

cadonna commented on a change in pull request #11149: URL: https://github.com/apache/kafka/pull/11149#discussion_r691098389 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsThreadTotalBlockedTime.java ## @@ -0,0 +1,59 @@ +/* + * Licensed

[GitHub] [kafka] guozhangwang commented on pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

guozhangwang commented on pull request #11184: URL: https://github.com/apache/kafka/pull/11184#issuecomment-900710127 Cherry-picked to 3.0 to be included in the 3.0 docs cc @kkonstantine -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [kafka] jolshan commented on pull request #11073: KAFKA-13092: Perf regression in LISR requests

jolshan commented on pull request #11073: URL: https://github.com/apache/kafka/pull/11073#issuecomment-901220052 Ah yes. I had a feeling I still had a pr open for this. I think I can clean it up a bit and it should be ready for review by tomorrow. -- This is an automated message from the

[GitHub] [kafka] rajinisivaram merged pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

rajinisivaram merged pull request #11221: URL: https://github.com/apache/kafka/pull/11221 -- 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: jira-uns

[GitHub] [kafka] guozhangwang commented on a change in pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

guozhangwang commented on a change in pull request #11184: URL: https://github.com/apache/kafka/pull/11184#discussion_r690792216 ## File path: docs/streams/upgrade-guide.html ## @@ -52,6 +52,15 @@ Upgrade Guide and API Changes restart all new ({{fullDotVersion}}) appl

[GitHub] [kafka] lbradstreet commented on a change in pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

lbradstreet commented on a change in pull request #11230: URL: https://github.com/apache/kafka/pull/11230#discussion_r691368381 ## File path: core/src/main/scala/kafka/server/ConfigHandler.scala ## @@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,

[GitHub] [kafka] guozhangwang merged pull request #11184: KAFKA-13172: Add downgrade guidance note for 3.0

guozhangwang merged pull request #11184: URL: https://github.com/apache/kafka/pull/11184 -- 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: jira-unsu

[GitHub] [kafka] junrao commented on a change in pull request #11216: KAFKA-13198: Stop replicas when reassigned

junrao commented on a change in pull request #11216: URL: https://github.com/apache/kafka/pull/11216#discussion_r690492221 ## File path: core/src/main/scala/kafka/server/BrokerServer.scala ## @@ -113,7 +113,7 @@ class BrokerServer( var dynamicConfigHandlers: Map[String, Co

[GitHub] [kafka] dajac commented on pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

dajac commented on pull request #11221: URL: https://github.com/apache/kafka/pull/11221#issuecomment-900541736 @rajinisivaram Should we also add it to 2.8 branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [kafka] dajac commented on a change in pull request #11225: MINOR; Small optimizations in `ReplicaManager#becomeLeaderOrFollower`

dajac commented on a change in pull request #11225: URL: https://github.com/apache/kafka/pull/11225#discussion_r691041467 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig, le

[GitHub] [kafka] Justinwins commented on a change in pull request #10652: KAFKA-9726 IdentityReplicationPolicy

Justinwins commented on a change in pull request #10652: URL: https://github.com/apache/kafka/pull/10652#discussion_r684042834 ## File path: docs/upgrade.html ## @@ -83,7 +83,13 @@ Notable changes in 3 understood by brokers or version 2.5 or higher, so you must upgrade

[GitHub] [kafka] jlprat commented on pull request #11228: KAFKA-12887 Skip some RuntimeExceptions from exception handler

jlprat commented on pull request #11228: URL: https://github.com/apache/kafka/pull/11228#issuecomment-901030641 -- 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 unsubscri

[GitHub] [kafka] vvcephei commented on a change in pull request #11213: KAFKA-13201: Convert KTable aggregations to new PAPI

vvcephei commented on a change in pull request #11213: URL: https://github.com/apache/kafka/pull/11213#discussion_r690642563 ## File path: streams/src/test/java/org/apache/kafka/test/MockInternalNewProcessorContext.java ## @@ -0,0 +1,172 @@ +/* + * Licensed to the Apache Softw

[GitHub] [kafka] showuon commented on a change in pull request #11227: KAFKA-13211: add support for infinite range query for WindowStore

showuon commented on a change in pull request #11227: URL: https://github.com/apache/kafka/pull/11227#discussion_r691052026 ## File path: streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java ## @@ -124,8 +124,8 @@ fi

[GitHub] [kafka] rajinisivaram commented on pull request #11221: KAFKA-13207: Skip truncation on fetch response with diverging epoch if partition removed from fetcher

rajinisivaram commented on pull request #11221: URL: https://github.com/apache/kafka/pull/11221#issuecomment-900433010 -- 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 un

[GitHub] [kafka] jomach commented on pull request #9493: KAFKA-10640: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSO

jomach commented on pull request #9493: URL: https://github.com/apache/kafka/pull/9493#issuecomment-901121979 seems to be some conflicts. @joshuagrisham can you fix them please ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [kafka] dajac commented on pull request #11073: KAFKA-13092: Perf regression in LISR requests

dajac commented on pull request #11073: URL: https://github.com/apache/kafka/pull/11073#issuecomment-901015825 @jolshan is it something that we must add to 2.8.1? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [kafka] yangdaixai closed pull request #11185: KAFKA-13175; Better indicates for created topic is marked for deleti…

yangdaixai closed pull request #11185: URL: https://github.com/apache/kafka/pull/11185 -- 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: jira-unsubs

[GitHub] [kafka] junrao merged pull request #11216: KAFKA-13198: Stop replicas when reassigned

junrao merged pull request #11216: URL: https://github.com/apache/kafka/pull/11216 -- 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: jira-unsubscr..

[GitHub] [kafka] jsancio commented on a change in pull request #11216: KAFKA-13198: Stop replicas when reassigned

jsancio commented on a change in pull request #11216: URL: https://github.com/apache/kafka/pull/11216#discussion_r690620725 ## File path: core/src/main/scala/kafka/server/BrokerServer.scala ## @@ -113,7 +113,7 @@ class BrokerServer( var dynamicConfigHandlers: Map[String, C

[jira] [Assigned] (KAFKA-13214) Consumer should not reset group state after disconnect

[ https://issues.apache.org/jira/browse/KAFKA-13214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-13214: --- Assignee: Jason Gustafson > Consumer should not reset group state after disconnect

[jira] [Commented] (KAFKA-12713) Report "REAL" follower/consumer fetch latency

[ https://issues.apache.org/jira/browse/KAFKA-12713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401270#comment-17401270 ] Kai Huang commented on KAFKA-12713: --- [~ijuma] Thanks for the pointer. I've bumped up t

[GitHub] [kafka] lbradstreet commented on a change in pull request #11230: KAFKA-12840; Removing `compact` cleaning on a topic should abort on-going compactions

lbradstreet commented on a change in pull request #11230: URL: https://github.com/apache/kafka/pull/11230#discussion_r691487441 ## File path: core/src/main/scala/kafka/server/ConfigHandler.scala ## @@ -66,8 +66,13 @@ class TopicConfigHandler(private val logManager: LogManager,

[GitHub] [kafka] hachikuji opened a new pull request #11231: KAFKA-13214; Consumer should not reset state after retriable error in rebalance

hachikuji opened a new pull request #11231: URL: https://github.com/apache/kafka/pull/11231 Currently the consumer will reset state after any retriable error during a rebalance. This includes coordinator disconnects as well as coordinator changes. The impact of this is that rebalances get

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401302#comment-17401302 ] Matthias J. Sax commented on KAFKA-13152: - [~guozhang] – your proposal to only p

[GitHub] [kafka] hachikuji commented on a change in pull request #11231: KAFKA-13214; Consumer should not reset state after retriable error in rebalance

hachikuji commented on a change in pull request #11231: URL: https://github.com/apache/kafka/pull/11231#discussion_r691522435 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -476,7 +476,6 @@ boolean joinGroupIfNeed

[GitHub] [kafka] hachikuji commented on a change in pull request #11231: KAFKA-13214; Consumer should not reset state after retriable error in rebalance

hachikuji commented on a change in pull request #11231: URL: https://github.com/apache/kafka/pull/11231#discussion_r691522435 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -476,7 +476,6 @@ boolean joinGroupIfNeed

[jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

[ https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401318#comment-17401318 ] Guozhang Wang commented on KAFKA-13152: --- I think it's a good idea to continue our

[GitHub] [kafka] guozhangwang commented on a change in pull request #11149: KIP-761: add total blocked time metric to streams

guozhangwang commented on a change in pull request #11149: URL: https://github.com/apache/kafka/pull/11149#discussion_r691613659 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java ## @@ -1121,4 +1125,60 @@ public void sho

[jira] [Created] (KAFKA-13216) Streams left/outer joins cause new internal changelog topic to grow unbounded

Sergio Peña created KAFKA-13216: --- Summary: Streams left/outer joins cause new internal changelog topic to grow unbounded Key: KAFKA-13216 URL: https://issues.apache.org/jira/browse/KAFKA-13216 Project:

[GitHub] [kafka] ableegoldman commented on a change in pull request #11124: KAFKA-12839: Let SlidingWindows aggregation support window size of 0

ableegoldman commented on a change in pull request #11124: URL: https://github.com/apache/kafka/pull/11124#discussion_r691646220 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -100,17 +99,78 @@

[GitHub] [kafka] ableegoldman merged pull request #11068: KAFKA-13081: detect doubly assigned parition (for v2.8)

ableegoldman merged pull request #11068: URL: https://github.com/apache/kafka/pull/11068 -- 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: jira-unsu

[jira] [Commented] (KAFKA-12550) Introduce RESTORING state to the KafkaStreams FSM

[ https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401408#comment-17401408 ] A. Sophie Blee-Goldman commented on KAFKA-12550: Yeah, the RESTORING wou

[GitHub] [kafka] ableegoldman commented on pull request #11217: KAFKA-13204: assignor name conflict check

ableegoldman commented on pull request #11217: URL: https://github.com/apache/kafka/pull/11217#issuecomment-901515775 Test failure is unrelated: `StoreQueryIntegrationTest.shouldQueryStoresAfterAddingAndRemovingStreamThread` -- This is an automated message from the Apache Git Service. To

[GitHub] [kafka] ableegoldman commented on pull request #11217: KAFKA-13204: assignor name conflict check

ableegoldman commented on pull request #11217: URL: https://github.com/apache/kafka/pull/11217#issuecomment-901516021 Merged to trunk -- 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

[GitHub] [kafka] ableegoldman merged pull request #11217: KAFKA-13204: assignor name conflict check

ableegoldman merged pull request #11217: URL: https://github.com/apache/kafka/pull/11217 -- 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: jira-unsu

[GitHub] [kafka] hachikuji commented on a change in pull request #11229: KAFKA-12961; Verify group generation in `DelayedJoin`

hachikuji commented on a change in pull request #11229: URL: https://github.com/apache/kafka/pull/11229#discussion_r691694091 ## File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala ## @@ -1391,78 +1392,92 @@ class GroupCoordinator(val brokerId: Int,

[GitHub] [kafka] kkonstantine opened a new pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

kkonstantine opened a new pull request #11232: URL: https://github.com/apache/kafka/pull/11232 One new dependency was missing a license entry [jline](https://github.com/jline/jline3) The rest of the changes correspond to updated package versions. No functional changes in the code

[jira] [Commented] (KAFKA-12994) Migrate all Tests to New API and Remove Suppression for Deprecation Warnings related to KIP-633

[ https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401410#comment-17401410 ] A. Sophie Blee-Goldman commented on KAFKA-12994: Hey guys, thanks for pi

[jira] [Updated] (KAFKA-13216) Streams left/outer joins cause new internal changelog topic to grow unbounded

[ https://issues.apache.org/jira/browse/KAFKA-13216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-13216: Fix Version/s: 3.0.0 > Streams left/outer joins cause new internal changelog topic to grow

[GitHub] [kafka] hachikuji commented on a change in pull request #11225: MINOR; Small optimizations in `ReplicaManager#becomeLeaderOrFollower`

hachikuji commented on a change in pull request #11225: URL: https://github.com/apache/kafka/pull/11225#discussion_r691703790 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,

[GitHub] [kafka] rhauch commented on a change in pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

rhauch commented on a change in pull request #11232: URL: https://github.com/apache/kafka/pull/11232#discussion_r691705388 ## File path: LICENSE-binary ## @@ -208,52 +208,52 @@ License Version 2.0: audience-annotations-0.5.0 commons-cli-1.4 commons-lang3-3.8.1 -jackson-annot

[GitHub] [kafka] hachikuji commented on a change in pull request #11225: MINOR; Small optimizations in `ReplicaManager#becomeLeaderOrFollower`

hachikuji commented on a change in pull request #11225: URL: https://github.com/apache/kafka/pull/11225#discussion_r691706079 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1436,17 +1438,15 @@ class ReplicaManager(val config: KafkaConfig,

[GitHub] [kafka] rhauch commented on pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

rhauch commented on pull request #11232: URL: https://github.com/apache/kafka/pull/11232#issuecomment-901534553 Do you plan to backport this, and if so to what branches? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] kkonstantine commented on a change in pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

kkonstantine commented on a change in pull request #11232: URL: https://github.com/apache/kafka/pull/11232#discussion_r691710309 ## File path: LICENSE-binary ## @@ -208,52 +208,52 @@ License Version 2.0: audience-annotations-0.5.0 commons-cli-1.4 commons-lang3-3.8.1 -jackson

[GitHub] [kafka] kkonstantine commented on a change in pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

kkonstantine commented on a change in pull request #11232: URL: https://github.com/apache/kafka/pull/11232#discussion_r691710309 ## File path: LICENSE-binary ## @@ -208,52 +208,52 @@ License Version 2.0: audience-annotations-0.5.0 commons-cli-1.4 commons-lang3-3.8.1 -jackson

[GitHub] [kafka] kkonstantine commented on a change in pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

kkonstantine commented on a change in pull request #11232: URL: https://github.com/apache/kafka/pull/11232#discussion_r691710720 ## File path: LICENSE-binary ## @@ -208,52 +208,52 @@ License Version 2.0: audience-annotations-0.5.0 commons-cli-1.4 commons-lang3-3.8.1 -jackson

[GitHub] [kafka] kkonstantine commented on a change in pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

kkonstantine commented on a change in pull request #11232: URL: https://github.com/apache/kafka/pull/11232#discussion_r691710928 ## File path: LICENSE-binary ## @@ -208,52 +208,52 @@ License Version 2.0: audience-annotations-0.5.0 commons-cli-1.4 commons-lang3-3.8.1 -jackson

[GitHub] [kafka] kkonstantine commented on pull request #11232: MINOR: Update package versions in LICENSE-binary for 3.0

kkonstantine commented on pull request #11232: URL: https://github.com/apache/kafka/pull/11232#issuecomment-901540065 Hey @rhauch. I replied to the other comments inline. Regarding your question: > Do you plan to backport this, and if so to what branches? This was run against

  1   2   >