[jira] [Commented] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

[ https://issues.apache.org/jira/browse/KAFKA-12920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370370#comment-17370370 ] Guozhang Wang commented on KAFKA-12920: --- Adding the other created root cause issue ticket here. >

[jira] [Commented] (KAFKA-12378) If a broker is down for more then `delete.retention.ms` deleted records in a compacted topic can come back.

[ https://issues.apache.org/jira/browse/KAFKA-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370369#comment-17370369 ] Guozhang Wang commented on KAFKA-12378: --- Hello [~shanesaww], I agree this is a tricky problem to

[jira] [Commented] (KAFKA-12559) Add a top-level Streams config for bounding off-heap memory

[ https://issues.apache.org/jira/browse/KAFKA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370331#comment-17370331 ] Guozhang Wang commented on KAFKA-12559: --- [~msundeq] I've re-assigned the ticket for you. Please

[jira] [Assigned] (KAFKA-12559) Add a top-level Streams config for bounding off-heap memory

[ https://issues.apache.org/jira/browse/KAFKA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-12559: - Assignee: Martin Sundeqvist (was: amuthan Ganeshan) > Add a top-level Streams config

[jira] [Assigned] (KAFKA-12995) AdminClient listOffsets fail with old Kafka Broker

[ https://issues.apache.org/jira/browse/KAFKA-12995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-12995: - Assignee: Alan Artigao Carreño > AdminClient listOffsets fail with old Kafka Broker >

[jira] [Commented] (KAFKA-12889) log clean group consider empty log segment to avoid empty log left

[ https://issues.apache.org/jira/browse/KAFKA-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366024#comment-17366024 ] Guozhang Wang commented on KAFKA-12889: --- Thanks [~iamgd67] for reporting the issue and for the fix

[jira] [Commented] (KAFKA-12870) RecordAccumulator stuck in a flushing state

[ https://issues.apache.org/jira/browse/KAFKA-12870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365660#comment-17365660 ] Guozhang Wang commented on KAFKA-12870: --- This is a great find. Though it might not related to

[jira] [Created] (KAFKA-12957) Refactor Streams Logical Plan Generation

Guozhang Wang created KAFKA-12957: - Summary: Refactor Streams Logical Plan Generation Key: KAFKA-12957 URL: https://issues.apache.org/jira/browse/KAFKA-12957 Project: Kafka Issue Type:

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

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

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

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

[jira] [Updated] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

[ https://issues.apache.org/jira/browse/KAFKA-12920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12920: -- Issue Type: Bug (was: Improvement) > Consumer's cooperative sticky assignor need to clear

[jira] [Created] (KAFKA-12920) Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost`

Guozhang Wang created KAFKA-12920: - Summary: Consumer's cooperative sticky assignor need to clear generation / assignment data upon `onPartitionsLost` Key: KAFKA-12920 URL:

[jira] [Closed] (KAFKA-12918) Watch-Free Animated 'America: The Motion Picture' Trailer 2021 Full Hd Download

[ https://issues.apache.org/jira/browse/KAFKA-12918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang closed KAFKA-12918. - > Watch-Free Animated 'America: The Motion Picture' Trailer 2021 Full Hd > Download >

[jira] [Resolved] (KAFKA-12918) Watch-Free Animated 'America: The Motion Picture' Trailer 2021 Full Hd Download

[ https://issues.apache.org/jira/browse/KAFKA-12918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12918. --- > Watch-Free Animated 'America: The Motion Picture' Trailer 2021 Full Hd > Download >

[jira] [Resolved] (KAFKA-10614) Group coordinator onElection/onResignation should guard against leader epoch

[ https://issues.apache.org/jira/browse/KAFKA-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-10614. --- Fix Version/s: 3.0.0 Resolution: Fixed > Group coordinator onElection/onResignation

[jira] [Updated] (KAFKA-12370) Refactor KafkaStreams exposed metadata hierarchy

[ https://issues.apache.org/jira/browse/KAFKA-12370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12370: -- Description: Currently in KafkaStreams we have two groups of metadata getter: 1. {code}

[jira] [Created] (KAFKA-12887) Do not trigger user-customized ExceptionalHandler for RTE

Guozhang Wang created KAFKA-12887: - Summary: Do not trigger user-customized ExceptionalHandler for RTE Key: KAFKA-12887 URL: https://issues.apache.org/jira/browse/KAFKA-12887 Project: Kafka

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12878: -- Priority: Critical (was: Major) > Support --bootstrap-server kafka-streams-application-reset

[jira] [Updated] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12878: -- Fix Version/s: 3.0.0 > Support --bootstrap-server kafka-streams-application-reset >

[jira] [Commented] (KAFKA-12878) Support --bootstrap-server kafka-streams-application-reset

[ https://issues.apache.org/jira/browse/KAFKA-12878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356001#comment-17356001 ] Guozhang Wang commented on KAFKA-12878: --- [~nbuesing] Could you please file a small KIP to announce

[jira] [Commented] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17356000#comment-17356000 ] Guozhang Wang commented on KAFKA-12718: --- Hi folks, I'm bumping up the priority of this ticket for

[jira] [Updated] (KAFKA-12718) SessionWindows are closed too early

[ https://issues.apache.org/jira/browse/KAFKA-12718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12718: -- Priority: Critical (was: Major) > SessionWindows are closed too early >

[jira] [Commented] (KAFKA-12743) [Kafka Streams] - cluster failover for stateful Kafka Streams applications

[ https://issues.apache.org/jira/browse/KAFKA-12743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348830#comment-17348830 ] Guozhang Wang commented on KAFKA-12743: --- For example, there are a few open source projects like

[jira] [Commented] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348068#comment-17348068 ] Guozhang Wang commented on KAFKA-12815: --- Yup, we are definitely fixing forward rather than

[jira] [Commented] (KAFKA-12743) [Kafka Streams] - cluster failover for stateful Kafka Streams applications

[ https://issues.apache.org/jira/browse/KAFKA-12743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348063#comment-17348063 ] Guozhang Wang commented on KAFKA-12743: --- I think the statement should be "Streams does not have a

[jira] [Commented] (KAFKA-12815) KTable.transformValue might have incorrect record metadata

[ https://issues.apache.org/jira/browse/KAFKA-12815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347995#comment-17347995 ] Guozhang Wang commented on KAFKA-12815: --- For the longer term, I feel that we either need to 1)

[jira] [Commented] (KAFKA-12812) Consider refactoring state store registration path

[ https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347051#comment-17347051 ] Guozhang Wang commented on KAFKA-12812: --- The reason I feel this is better is that, it could be

[jira] [Created] (KAFKA-12812) Consider refactoring state store registration path

Guozhang Wang created KAFKA-12812: - Summary: Consider refactoring state store registration path Key: KAFKA-12812 URL: https://issues.apache.org/jira/browse/KAFKA-12812 Project: Kafka Issue

[jira] [Commented] (KAFKA-10594) Enhance Raft exception handling

[ https://issues.apache.org/jira/browse/KAFKA-10594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345868#comment-17345868 ] Guozhang Wang commented on KAFKA-10594: --- Thanks for filing this Boyang. I also agree with

[jira] [Commented] (KAFKA-12781) Improve the endOffsets accuracy in TaskMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345867#comment-17345867 ] Guozhang Wang commented on KAFKA-12781: --- I did not review the original PR so do not know we were

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345836#comment-17345836 ] Guozhang Wang commented on KAFKA-12776: --- I think KIP-739 is relatively orthogonal to the scenario

[jira] [Commented] (KAFKA-12776) Producer sends messages out-of-order inspite of enabling idempotence

[ https://issues.apache.org/jira/browse/KAFKA-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345822#comment-17345822 ] Guozhang Wang commented on KAFKA-12776: --- Hey [~neeraj.vaidya], thanks for your updates, they are

[jira] [Updated] (KAFKA-12747) Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix

[ https://issues.apache.org/jira/browse/KAFKA-12747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12747: -- Fix Version/s: 2.8.1 > Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix >

[jira] [Assigned] (KAFKA-12747) Flaky Test RocksDBStoreTest.shouldReturnUUIDsWithStringPrefix

[ https://issues.apache.org/jira/browse/KAFKA-12747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-12747: - Fix Version/s: 3.0.0 Assignee: Guozhang Wang Resolution: Fixed > Flaky

[jira] [Updated] (KAFKA-12748) Explore new RocksDB options to consider enabling by default

[ https://issues.apache.org/jira/browse/KAFKA-12748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12748: -- Labels: rocksdb (was: ) > Explore new RocksDB options to consider enabling by default >

[jira] [Commented] (KAFKA-12748) Explore new RocksDB options to consider enabling by default

[ https://issues.apache.org/jira/browse/KAFKA-12748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339399#comment-17339399 ] Guozhang Wang commented on KAFKA-12748: --- Thanks for making a pass on the new options! This is a

[jira] [Commented] (KAFKA-12743) [Kafka Streams] - regex name for state-store change-log topic

[ https://issues.apache.org/jira/browse/KAFKA-12743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338607#comment-17338607 ] Guozhang Wang commented on KAFKA-12743: --- Yeah that's a good point. I think your workaround makes

[jira] [Commented] (KAFKA-12743) [Kafka Streams] - regex name for state-store change-log topic

[ https://issues.apache.org/jira/browse/KAFKA-12743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338496#comment-17338496 ] Guozhang Wang commented on KAFKA-12743: --- Hi [~Sg12] just to better understand your scenarios here:

[jira] [Resolved] (KAFKA-12683) Remove deprecated "UsePreviousTimeOnInvalidTimeStamp"

[ https://issues.apache.org/jira/browse/KAFKA-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12683. --- Fix Version/s: 3.0.0 Assignee: Guozhang Wang Resolution: Fixed > Remove

[jira] [Commented] (KAFKA-12711) Add a back off option to replace thread

[ https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331098#comment-17331098 ] Guozhang Wang commented on KAFKA-12711: --- On the other hand, I think maybe we do not, at least in

[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=17331097#comment-17331097 ] Guozhang Wang commented on KAFKA-10493: --- Without KIP-280, it would always be an issue; what I'm

[jira] [Commented] (KAFKA-12711) Add a back off option to replace thread

[ https://issues.apache.org/jira/browse/KAFKA-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331095#comment-17331095 ] Guozhang Wang commented on KAFKA-12711: --- I'm +1 for this feature. Generally speaking, we should

[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=17330987#comment-17330987 ] Guozhang Wang commented on KAFKA-10493: --- While thinking about

[jira] [Updated] (KAFKA-12693) Consecutive rebalances with zombie instances may cause corrupted changelogs

[ https://issues.apache.org/jira/browse/KAFKA-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12693: -- Labels: streams (was: ) > Consecutive rebalances with zombie instances may cause corrupted

[jira] [Commented] (KAFKA-12710) Consider enabling (at least some) optimizations by default

[ https://issues.apache.org/jira/browse/KAFKA-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330979#comment-17330979 ] Guozhang Wang commented on KAFKA-12710: --- Thanks [~ableegoldman], this seems relevant to

[jira] [Created] (KAFKA-12693) Consecutive rebalances with zombie instances may cause corrupted changelogs

Guozhang Wang created KAFKA-12693: - Summary: Consecutive rebalances with zombie instances may cause corrupted changelogs Key: KAFKA-12693 URL: https://issues.apache.org/jira/browse/KAFKA-12693

[jira] [Commented] (KAFKA-12675) Improve sticky general assignor scalability and performance

[ https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325234#comment-17325234 ] Guozhang Wang commented on KAFKA-12675: --- Wow this is super! Thanks [~showuon] [~twmb], please ping

[jira] [Commented] (KAFKA-12669) Add deleteRange to WindowStore / KeyValueStore interfaces

[ https://issues.apache.org/jira/browse/KAFKA-12669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324575#comment-17324575 ] Guozhang Wang commented on KAFKA-12669: --- Hi [~dongjin] , thanks for your interests! It is for

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324574#comment-17324574 ] Guozhang Wang commented on KAFKA-9168: -- Hi [~sagarrao] just for my own education could you paste the

[jira] [Created] (KAFKA-12683) Remove deprecated "UsePreviousTimeOnInvalidTimeStamp"

Guozhang Wang created KAFKA-12683: - Summary: Remove deprecated "UsePreviousTimeOnInvalidTimeStamp" Key: KAFKA-12683 URL: https://issues.apache.org/jira/browse/KAFKA-12683 Project: Kafka

[jira] [Resolved] (KAFKA-12633) Remove deprecated "TopologyTestDriver#pipeInput / readOutput"

[ https://issues.apache.org/jira/browse/KAFKA-12633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12633. --- Fix Version/s: 3.0.0 Resolution: Fixed > Remove deprecated

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322417#comment-17322417 ] Guozhang Wang commented on KAFKA-12574: --- Hi [~feyman] I'm aware of KAFKA-9689 as well, and also

[jira] [Created] (KAFKA-12669) Add deleteRange to WindowStore / KeyValueStore interfaces

Guozhang Wang created KAFKA-12669: - Summary: Add deleteRange to WindowStore / KeyValueStore interfaces Key: KAFKA-12669 URL: https://issues.apache.org/jira/browse/KAFKA-12669 Project: Kafka

[jira] [Commented] (KAFKA-12370) Refactor KafkaStreams exposed metadata hierarchy

[ https://issues.apache.org/jira/browse/KAFKA-12370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321230#comment-17321230 ] Guozhang Wang commented on KAFKA-12370: --- Another idea to add: maybe we can also add an

[jira] [Resolved] (KAFKA-12643) Kafka Streams 2.7 with Kafka Broker 2.6.x regression: bad timestamp in transform/process (this.context.schedule function)

[ https://issues.apache.org/jira/browse/KAFKA-12643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12643. --- Resolution: Duplicate Thanks for confirming! > Kafka Streams 2.7 with Kafka Broker 2.6.x

[jira] [Commented] (KAFKA-12642) Improve Rebalance reason upon metadata change

[ https://issues.apache.org/jira/browse/KAFKA-12642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319766#comment-17319766 ] Guozhang Wang commented on KAFKA-12642: --- Hi [~nicolas.guyomar] Maybe in the existing log message,

[jira] [Updated] (KAFKA-10888) Sticky partition leads to uneven product msg, resulting in abnormal delays in some partitions

[ https://issues.apache.org/jira/browse/KAFKA-10888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10888: -- Summary: Sticky partition leads to uneven product msg, resulting in abnormal delays in some

[jira] [Commented] (KAFKA-12643) Kafka Streams 2.7 with Kafka Broker 2.6.x regression: bad timestamp in transform/process (this.context.schedule function)

[ https://issues.apache.org/jira/browse/KAFKA-12643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318116#comment-17318116 ] Guozhang Wang commented on KAFKA-12643: --- Hello [~devano], thanks for reporting this issue, could

[jira] [Created] (KAFKA-12633) Remove deprecated "TopologyTestDriver#pipeInput / readOutput"

Guozhang Wang created KAFKA-12633: - Summary: Remove deprecated "TopologyTestDriver#pipeInput / readOutput" Key: KAFKA-12633 URL: https://issues.apache.org/jira/browse/KAFKA-12633 Project: Kafka

[jira] [Resolved] (KAFKA-12630) Remove deprecated KafkaClientSupplier#getAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-12630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12630. --- Fix Version/s: 3.0.0 Resolution: Fixed > Remove deprecated

[jira] [Resolved] (KAFKA-12568) Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

[ https://issues.apache.org/jira/browse/KAFKA-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12568. --- Fix Version/s: 3.0.0 Assignee: Guozhang Wang Resolution: Fixed > Remove

[jira] [Created] (KAFKA-12630) Remove deprecated KafkaClientSupplier#getAdminClient

Guozhang Wang created KAFKA-12630: - Summary: Remove deprecated KafkaClientSupplier#getAdminClient Key: KAFKA-12630 URL: https://issues.apache.org/jira/browse/KAFKA-12630 Project: Kafka Issue

[jira] [Resolved] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7785. -- Resolution: Fixed > Remove PartitionGrouper interface and it's config and move >

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315153#comment-17315153 ] Guozhang Wang commented on KAFKA-12574: --- I'm fine with option 2) as well, to stay with `eos-v2`

[jira] [Updated] (KAFKA-12607) Allow votes to be granted in resigned state

[ https://issues.apache.org/jira/browse/KAFKA-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12607: -- Labels: newbie++ (was: ) > Allow votes to be granted in resigned state >

[jira] [Commented] (KAFKA-9765) Could not add partitions to transaction due to errors

[ https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17314112#comment-17314112 ] Guozhang Wang commented on KAFKA-9765: -- Thanks for conforming. I'm closing this ticket for now. >

[jira] [Resolved] (KAFKA-9765) Could not add partitions to transaction due to errors

[ https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9765. -- Resolution: Duplicate > Could not add partitions to transaction due to errors >

[jira] [Updated] (KAFKA-9765) Could not add partitions to transaction due to errors

[ https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-9765: - Fix Version/s: 2.5.0 2.4.2 > Could not add partitions to transaction due to

[jira] [Comment Edited] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312782#comment-17312782 ] Guozhang Wang edited comment on KAFKA-12574 at 4/1/21, 11:22 PM: - Okay,

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312782#comment-17312782 ] Guozhang Wang commented on KAFKA-12574: --- Okay, if we are concerned about 4) to be too aggressive,

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311995#comment-17311995 ] Guozhang Wang commented on KAFKA-12574: --- Yeah I think in 3.0 we would not remove the old eos

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311697#comment-17311697 ] Guozhang Wang commented on KAFKA-12574: --- Yeah.. I also felt this procedure requires users to "jump

[jira] [Commented] (KAFKA-12574) Deprecate eos-alpha

[ https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311648#comment-17311648 ] Guozhang Wang commented on KAFKA-12574: --- I agree we should try to encourage users to switch to the

[jira] [Resolved] (KAFKA-12428) Add a last-heartbeat-seconds-ago metric to Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12428. --- Resolution: Duplicate > Add a last-heartbeat-seconds-ago metric to Kafka Consumer >

[jira] [Commented] (KAFKA-12428) Add a last-heartbeat-seconds-ago metric to Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310964#comment-17310964 ] Guozhang Wang commented on KAFKA-12428: --- Just realized it is already added, I'm going to close

[jira] [Updated] (KAFKA-12549) Allow state stores to opt-in transactional support

[ https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12549: -- Description: Right now Kafka Stream's EOS implementation does not make any assumptions about

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310408#comment-17310408 ] Guozhang Wang commented on KAFKA-9552: -- There are some discussions in the past. In

[jira] [Resolved] (KAFKA-7106) Remove segment/segmentInterval from Window definition

[ https://issues.apache.org/jira/browse/KAFKA-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7106. -- Resolution: Fixed > Remove segment/segmentInterval from Window definition >

[jira] [Resolved] (KAFKA-12562) Remove deprecated-overloaded "KafkaStreams#metadataForKey" and "KafkaStreams#store"

[ https://issues.apache.org/jira/browse/KAFKA-12562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12562. --- Resolution: Fixed > Remove deprecated-overloaded "KafkaStreams#metadataForKey" and >

[jira] [Commented] (KAFKA-12478) Consumer group may lose data for newly expanded partitions when add partitions for topic if the group is set to consume from the latest

[ https://issues.apache.org/jira/browse/KAFKA-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310106#comment-17310106 ] Guozhang Wang commented on KAFKA-12478: --- Thanks [~hudeqi]. I think it is still better to implement

[jira] [Updated] (KAFKA-3370) Add options to auto.offset.reset to reset offsets upon initialization only

[ https://issues.apache.org/jira/browse/KAFKA-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3370: - Labels: needs-kip (was: ) > Add options to auto.offset.reset to reset offsets upon

[jira] [Resolved] (KAFKA-12524) Remove deprecated WindowBytesStoreSupplier#segments

[ https://issues.apache.org/jira/browse/KAFKA-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12524. --- Resolution: Fixed > Remove deprecated WindowBytesStoreSupplier#segments >

[jira] [Created] (KAFKA-12568) Remove deprecated "KStream#groupBy/join", "Joined#named" overloads

Guozhang Wang created KAFKA-12568: - Summary: Remove deprecated "KStream#groupBy/join", "Joined#named" overloads Key: KAFKA-12568 URL: https://issues.apache.org/jira/browse/KAFKA-12568 Project: Kafka

[jira] [Commented] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310098#comment-17310098 ] Guozhang Wang commented on KAFKA-12499: --- I also think checking commit interval < transaction

[jira] [Updated] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

[ https://issues.apache.org/jira/browse/KAFKA-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12499: -- Priority: Blocker (was: Major) > Adjust transaction timeout according to commit interval on

[jira] [Created] (KAFKA-12562) Remove deprecated-overloaded "KafkaStreams#metadataForKey" and "KafkaStreams#store"

Guozhang Wang created KAFKA-12562: - Summary: Remove deprecated-overloaded "KafkaStreams#metadataForKey" and "KafkaStreams#store" Key: KAFKA-12562 URL: https://issues.apache.org/jira/browse/KAFKA-12562

[jira] [Resolved] (KAFKA-12527) Remove deprecated "PartitionGrouper" interface

[ https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12527. --- Resolution: Duplicate > Remove deprecated "PartitionGrouper" interface >

[jira] [Assigned] (KAFKA-12524) Remove deprecated WindowBytesStoreSupplier#segments

[ https://issues.apache.org/jira/browse/KAFKA-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-12524: - Assignee: Guozhang Wang > Remove deprecated WindowBytesStoreSupplier#segments >

[jira] [Updated] (KAFKA-7606) Remove deprecated options from StreamsResetter

[ https://issues.apache.org/jira/browse/KAFKA-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7606: - Parent: KAFKA-12419 Issue Type: Sub-task (was: Task) > Remove deprecated options from

[jira] [Updated] (KAFKA-7106) Remove segment/segmentInterval from Window definition

[ https://issues.apache.org/jira/browse/KAFKA-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7106: - Parent: KAFKA-12419 Issue Type: Sub-task (was: Improvement) > Remove

[jira] [Updated] (KAFKA-7785) Remove PartitionGrouper interface and it's config and move DefaultPartitionGrouper to internal package

[ https://issues.apache.org/jira/browse/KAFKA-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7785: - Parent: KAFKA-12419 Issue Type: Sub-task (was: Improvement) > Remove PartitionGrouper

[jira] [Resolved] (KAFKA-12526) Remove deprecated long ms overloads

[ https://issues.apache.org/jira/browse/KAFKA-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12526. --- Resolution: Duplicate > Remove deprecated long ms overloads >

[jira] [Updated] (KAFKA-12536) Add Instant-based methods to ReadOnlySessionStore

[ https://issues.apache.org/jira/browse/KAFKA-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12536: -- Parent: KAFKA-12419 (was: KAFKA-10434) > Add Instant-based methods to ReadOnlySessionStore >

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

[ https://issues.apache.org/jira/browse/KAFKA-10434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10434: -- Parent: KAFKA-12419 Issue Type: Sub-task (was: Improvement) > Remove deprecated

[jira] [Updated] (KAFKA-12450) Remove deprecated methods from ReadOnlyWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12450: -- Parent: KAFKA-12419 (was: KAFKA-10434) > Remove deprecated methods from ReadOnlyWindowStore

[jira] [Updated] (KAFKA-12451) Remove deprecation annotation on long-based read operations in WindowStore

[ https://issues.apache.org/jira/browse/KAFKA-12451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12451: -- Parent: KAFKA-12419 (was: KAFKA-10434) > Remove deprecation annotation on long-based read

[jira] [Commented] (KAFKA-12478) Consumer group may lose data for newly expanded partitions when add partitions for topic if the group is set to consume from the latest

[ https://issues.apache.org/jira/browse/KAFKA-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308875#comment-17308875 ] Guozhang Wang commented on KAFKA-12478: --- I think your way works too -- what I meant before is to

[jira] [Commented] (KAFKA-12478) Consumer group may lose data for newly expanded partitions when add partitions for topic if the group is set to consume from the latest

[ https://issues.apache.org/jira/browse/KAFKA-12478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308383#comment-17308383 ] Guozhang Wang commented on KAFKA-12478: --- Hello [~hudeqi] Thanks for the updates. I think I

[jira] [Updated] (KAFKA-12549) Allow state stores to opt-in transactional support

[ https://issues.apache.org/jira/browse/KAFKA-12549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12549: -- Description: Right now Kafka Stream's EOS implementation does not make any assumptions about

[jira] [Commented] (KAFKA-12527) Remove deprecated "PartitionGrouper" interface

[ https://issues.apache.org/jira/browse/KAFKA-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308245#comment-17308245 ] Guozhang Wang commented on KAFKA-12527: --- Ah yes, thanks! > Remove deprecated "PartitionGrouper"

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