[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093773#comment-17093773 ] Boyang Chen commented on KAFKA-9921: Hey [~georgi.petkov], would you mind explaining why you want to

[jira] [Updated] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9859: --- Labels: newbie newbie++ (was: ) > kafka-streams-application-reset tool doesn't take into account

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092295#comment-17092295 ] Boyang Chen commented on KAFKA-9891: I made a try to replicate the scenario with integration test,

[jira] [Commented] (KAFKA-9913) TopologyDescription should expose all topic name progrematically

[ https://issues.apache.org/jira/browse/KAFKA-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091804#comment-17091804 ] Boyang Chen commented on KAFKA-9913: I'm fine with combining the two tickets in one KIP as this saves

[jira] [Created] (KAFKA-9911) Implement new producer fenced error

Boyang Chen created KAFKA-9911: -- Summary: Implement new producer fenced error Key: KAFKA-9911 URL: https://issues.apache.org/jira/browse/KAFKA-9911 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-9910) Implement new transaction timed out error

Boyang Chen created KAFKA-9910: -- Summary: Implement new transaction timed out error Key: KAFKA-9910 URL: https://issues.apache.org/jira/browse/KAFKA-9910 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-9882) Add Block getAssignments()

[ https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089006#comment-17089006 ] Boyang Chen commented on KAFKA-9882: So you are trying to reset offset every time when you restart

[jira] [Commented] (KAFKA-9882) Add Block getAssignments()

[ https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088917#comment-17088917 ] Boyang Chen commented on KAFKA-9882: I see, to make the discussion more effective, could you draft a

[jira] [Commented] (KAFKA-9882) Add Block getAssignments()

[ https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1708#comment-1708 ] Boyang Chen commented on KAFKA-9882: I checked back on the original KIP 

[jira] [Commented] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

[ https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088233#comment-17088233 ] Boyang Chen commented on KAFKA-9868: [https://github.com/apache/kafka/pull/8522] > Flaky Test >

[jira] [Commented] (KAFKA-9882) Add Block getAssignments()

[ https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088086#comment-17088086 ] Boyang Chen commented on KAFKA-9882: Thanks for the ticket. Are there any concrete use cases for

[jira] [Updated] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

[ https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9868: --- Description: h3. Error Message java.lang.AssertionError: Condition not met within timeout 15000.

[jira] [Assigned] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

[ https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9868: -- Assignee: Boyang Chen > Flaky Test >

[jira] [Assigned] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9891: -- Assignee: Boyang Chen > Invalid state store content after task migration with exactly_once

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088044#comment-17088044 ] Boyang Chen commented on KAFKA-9891: Thanks for the report, will take a look this week. > Invalid

[jira] [Commented] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

[ https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087999#comment-17087999 ] Boyang Chen commented on KAFKA-9868: [~ableegoldman]Do we have the failure log? > Flaky Test >

[jira] [Commented] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

[ https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087971#comment-17087971 ] Boyang Chen commented on KAFKA-9850: [~lkokhreidze] Since you haven't got a chance to reply, I will

[jira] [Updated] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

[ https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9850: --- Labels: help-wanted newbie newbie++ (was: ) > Move KStream#repartition operator validation during

[jira] [Commented] (KAFKA-9520) Deprecate ZooKeeper access for kafka-reassign-partitions.sh

[ https://issues.apache.org/jira/browse/KAFKA-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087896#comment-17087896 ] Boyang Chen commented on KAFKA-9520: [~cmccabe] Is this fixed? > Deprecate ZooKeeper access for

[jira] [Resolved] (KAFKA-8993) Add an EOS performance test suite similar to ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-8993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8993. Resolution: Won't Fix > Add an EOS performance test suite similar to ProducerPerformance >

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17086127#comment-17086127 ] Boyang Chen commented on KAFKA-9224: This basically goes back to what consistency guarantee for IQ

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Description: As of today, the Producer transaction manager bookkeeps the partitions involved with

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085163#comment-17085163 ] Boyang Chen commented on KAFKA-9224: [~vvcephei] [~guozhang]Yea, it's a typo, and I just fixed it. >

[jira] [Updated] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9224: --- Description: Currently under EOS, the uncommitted write could be reflected in the state store before

[jira] [Assigned] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9860: -- Assignee: (was: Boyang Chen) > Transactional Producer could pre-add partitions >

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Component/s: producer > Transactional Producer could pre-add partitions >

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Labels: need-kip (was: ) > Transactional Producer could pre-add partitions >

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Description: As of today, the Producer transaction manager bookkeeps the partitions involved with

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Summary: Transactional Producer could pre-add partitions (was: Transactional Producer could add

[jira] [Created] (KAFKA-9878) Block EndTxn call until the txn markers are committed

Boyang Chen created KAFKA-9878: -- Summary: Block EndTxn call until the txn markers are committed Key: KAFKA-9878 URL: https://issues.apache.org/jira/browse/KAFKA-9878 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084191#comment-17084191 ] Boyang Chen commented on KAFKA-9592: [~iamabug] Could you phrase the new comment for

[jira] [Resolved] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries

[ https://issues.apache.org/jira/browse/KAFKA-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8870. Resolution: Duplicate > Prevent dirty reads of Streams state store from Interactive queries >

[jira] [Updated] (KAFKA-9608) An EOS model simulation test

[ https://issues.apache.org/jira/browse/KAFKA-9608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9608: --- Description: We want to build a framework which could generate random events to process a simple EOS

[jira] [Resolved] (KAFKA-9764) Deprecate Stream Simple benchmark

[ https://issues.apache.org/jira/browse/KAFKA-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9764. Resolution: Fixed > Deprecate Stream Simple benchmark > - > >

[jira] [Resolved] (KAFKA-9793) Stream HandleAssignment should guarantee task close

[ https://issues.apache.org/jira/browse/KAFKA-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9793. Resolution: Fixed > Stream HandleAssignment should guarantee task close >

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082806#comment-17082806 ] Boyang Chen commented on KAFKA-9592: My expectation is that your mentioned exceptions could still be

[jira] [Commented] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

[ https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082518#comment-17082518 ] Boyang Chen commented on KAFKA-9850: Thanks for the reporting, do you want to pick this up? > Move

[jira] [Updated] (KAFKA-9860) Transactional Producer could add partitions by batch at the end

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Description: As of today, the Producer transaction manager bookkeeps the partitions involved with

[jira] [Created] (KAFKA-9860) Transactional Producer could add partitions by batch at the end

Boyang Chen created KAFKA-9860: -- Summary: Transactional Producer could add partitions by batch at the end Key: KAFKA-9860 URL: https://issues.apache.org/jira/browse/KAFKA-9860 Project: Kafka

[jira] [Commented] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082409#comment-17082409 ] Boyang Chen commented on KAFKA-9859: Thanks for reporting. From your observation, is there a regular

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080274#comment-17080274 ] Boyang Chen commented on KAFKA-9592: [~iamabug] Yes, I think your understanding is correct. > Safely

[jira] [Resolved] (KAFKA-9784) Add OffsetFetch to the concurrent coordinator test

[ https://issues.apache.org/jira/browse/KAFKA-9784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9784. Resolution: Fixed > Add OffsetFetch to the concurrent coordinator test >

[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=17080187#comment-17080187 ] Boyang Chen commented on KAFKA-9765: Thanks, I checked the broker side code and the logic to trigger

[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=17080007#comment-17080007 ] Boyang Chen commented on KAFKA-9765: [~waykarp] Is your broker also on 2.3? > Could not add

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079982#comment-17079982 ] Boyang Chen commented on KAFKA-9592: [~iamabug] I synced with [~guozhang] offline about the solution

[jira] [Assigned] (KAFKA-9840) Consumer should not use OffsetForLeaderEpoch without current epoch validation

[ https://issues.apache.org/jira/browse/KAFKA-9840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9840: -- Assignee: Boyang Chen > Consumer should not use OffsetForLeaderEpoch without current epoch

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078421#comment-17078421 ] Boyang Chen commented on KAFKA-9592: [~iamabug] Thanks for the check. I think the code example you

[jira] [Updated] (KAFKA-9751) Admin `FindCoordinator` call should go to controller instead of ZK

[ https://issues.apache.org/jira/browse/KAFKA-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9751: --- Parent: (was: KAFKA-9119) Issue Type: Improvement (was: Sub-task) > Admin

[jira] [Updated] (KAFKA-9751) Admin `FindCoordinator` call should go to controller instead of ZK

[ https://issues.apache.org/jira/browse/KAFKA-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9751: --- Parent: KAFKA-9705 Issue Type: Sub-task (was: Improvement) > Admin `FindCoordinator` call

[jira] [Commented] (KAFKA-9824) Consumer loses partition offset and resets post 2.4.1 version upgrade

[ https://issues.apache.org/jira/browse/KAFKA-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076491#comment-17076491 ] Boyang Chen commented on KAFKA-9824: Thanks for reporting. Does the lost partition happen after each

[jira] [Updated] (KAFKA-9821) Partition may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9821: --- Labels: need-kip (was: ) > Partition may skip assignment with static members and incremental

[jira] [Updated] (KAFKA-9705) Zookeeper mutation protocols should be redirected to Controller only

[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9705: --- Parent: (was: KAFKA-9119) Issue Type: Improvement (was: Sub-task) > Zookeeper mutation

[jira] [Updated] (KAFKA-9705) Zookeeper mutation protocols should be redirected to Controller only

[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9705: --- Summary: Zookeeper mutation protocols should be redirected to Controller only (was: Config changes

[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=17074809#comment-17074809 ] Boyang Chen commented on KAFKA-9765: Hey [~waykarp] the URL you put there is broken. > Could not add

[jira] [Resolved] (KAFKA-9809) Shrink transaction timeout for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9809. Resolution: Fixed > Shrink transaction timeout for Streams >

[jira] [Assigned] (KAFKA-9809) Shrink transaction timeout for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9809: -- Assignee: Boyang Chen > Shrink transaction timeout for Streams >

[jira] [Created] (KAFKA-9809) Shrink transaction timeout for Streams

Boyang Chen created KAFKA-9809: -- Summary: Shrink transaction timeout for Streams Key: KAFKA-9809 URL: https://issues.apache.org/jira/browse/KAFKA-9809 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9803: -- Assignee: Boyang Chen > Allow producers to recover gracefully from transaction timeouts >

[jira] [Commented] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073345#comment-17073345 ] Boyang Chen commented on KAFKA-9803: This sounds like a good improvement to Streams, as of today we

[jira] [Updated] (KAFKA-9793) Stream HandleAssignment should guarantee task close

[ https://issues.apache.org/jira/browse/KAFKA-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9793: --- Issue Type: Bug (was: Improvement) > Stream HandleAssignment should guarantee task close >

[jira] [Created] (KAFKA-9793) Stream HandleAssignment should guarantee task close

Boyang Chen created KAFKA-9793: -- Summary: Stream HandleAssignment should guarantee task close Key: KAFKA-9793 URL: https://issues.apache.org/jira/browse/KAFKA-9793 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Parent: KAFKA-8587 Issue Type: Sub-task (was: Improvement) > Producer could automatically

[jira] [Updated] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Summary: Producer could automatically downgrade TxnOffsetCommitRequest with internal flag (was:

[jira] [Updated] (KAFKA-9776) Producer should automatically downgrade TxnOffsetCommitRequest

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Affects Version/s: (was: 2.5.0) 2.6.0 > Producer should automatically

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071393#comment-17071393 ] Boyang Chen commented on KAFKA-8677: This also happens for trunk, FYI:  [2020-03-30T17:12:15-07:00]

[jira] [Assigned] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries

[ https://issues.apache.org/jira/browse/KAFKA-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8870: -- Assignee: Boyang Chen > Prevent dirty reads of Streams state store from Interactive queries >

[jira] [Commented] (KAFKA-9759) Add documentation change for KIP-562

[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071115#comment-17071115 ] Boyang Chen commented on KAFKA-9759: [~vinoth] sg, I will do this one myself just to make sure we

[jira] [Updated] (KAFKA-9757) Add documentation change for KIP-535

[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9757: --- Due Date: 1/Apr/20 > Add documentation change for KIP-535 > > >

[jira] [Commented] (KAFKA-9757) Add documentation change for KIP-535

[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071067#comment-17071067 ] Boyang Chen commented on KAFKA-9757: I'm not sure how to configure this, but let's say by 04/01 (this

[jira] [Assigned] (KAFKA-9759) Add documentation change for KIP-562

[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9759: -- Assignee: Boyang Chen (was: Navinder Brar) > Add documentation change for KIP-562 >

[jira] [Assigned] (KAFKA-9759) Add documentation change for KIP-562

[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9759: -- Assignee: Navinder Brar (was: Vinoth Chandar) > Add documentation change for KIP-562 >

[jira] [Created] (KAFKA-9784) Add OffsetFetch to the concurrent coordinator test

Boyang Chen created KAFKA-9784: -- Summary: Add OffsetFetch to the concurrent coordinator test Key: KAFKA-9784 URL: https://issues.apache.org/jira/browse/KAFKA-9784 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9779) Add version 2.5 to streams system tests

Boyang Chen created KAFKA-9779: -- Summary: Add version 2.5 to streams system tests Key: KAFKA-9779 URL: https://issues.apache.org/jira/browse/KAFKA-9779 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9772) Transactional offset commit fails with IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068343#comment-17068343 ] Boyang Chen commented on KAFKA-9772: Could we attach the full log here? > Transactional offset

[jira] [Created] (KAFKA-9764) Deprecate Stream Simple benchmark

Boyang Chen created KAFKA-9764: -- Summary: Deprecate Stream Simple benchmark Key: KAFKA-9764 URL: https://issues.apache.org/jira/browse/KAFKA-9764 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9760) Add EOS protocol changes to documentation

Boyang Chen created KAFKA-9760: -- Summary: Add EOS protocol changes to documentation Key: KAFKA-9760 URL: https://issues.apache.org/jira/browse/KAFKA-9760 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-9758) Add documentations for KIP-523 and KIP-527

[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9758: --- Description: As titled, tracking doc changes for 523 and 527 launched in stream 2.5. (was: This

[jira] [Assigned] (KAFKA-9759) Add documentation change for KIP-562

[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9759: -- Assignee: Vinoth Chandar > Add documentation change for KIP-562 >

[jira] [Created] (KAFKA-9759) Add documentation change for KIP-562

Boyang Chen created KAFKA-9759: -- Summary: Add documentation change for KIP-562 Key: KAFKA-9759 URL: https://issues.apache.org/jira/browse/KAFKA-9759 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-9758) Add documentations for Streams release

[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9758: --- Description: This ticket tracks the doc updates for a couple of KIPs launched in stream 2.5,

[jira] [Assigned] (KAFKA-9758) Add documentations for Streams release

[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9758: -- Assignee: Boyang Chen > Add documentations for Streams release >

[jira] [Created] (KAFKA-9758) Add documentations for Streams release

Boyang Chen created KAFKA-9758: -- Summary: Add documentations for Streams release Key: KAFKA-9758 URL: https://issues.apache.org/jira/browse/KAFKA-9758 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9757) Add documentation change for KIP-535

Boyang Chen created KAFKA-9757: -- Summary: Add documentation change for KIP-535 Key: KAFKA-9757 URL: https://issues.apache.org/jira/browse/KAFKA-9757 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9475. Resolution: Won't Fix It seems not worth the effort as we could just shrink the scheduler time >

[jira] [Resolved] (KAFKA-9743) StreamTask could fail to close during HandleNewAssignment

[ https://issues.apache.org/jira/browse/KAFKA-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9743. Resolution: Fixed > StreamTask could fail to close during HandleNewAssignment >

[jira] [Resolved] (KAFKA-8230) Add static membership support in librd consumer client

[ https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8230. Resolution: Fixed Will be tracked on the librdKafka side, which seems to be done > Add static

[jira] [Created] (KAFKA-9751) Admin `FindCoordinator` call should go to controller instead of ZK

Boyang Chen created KAFKA-9751: -- Summary: Admin `FindCoordinator` call should go to controller instead of ZK Key: KAFKA-9751 URL: https://issues.apache.org/jira/browse/KAFKA-9751 Project: Kafka

[jira] [Created] (KAFKA-9743) StreamTask could fail to close during HandleNewAssignment

Boyang Chen created KAFKA-9743: -- Summary: StreamTask could fail to close during HandleNewAssignment Key: KAFKA-9743 URL: https://issues.apache.org/jira/browse/KAFKA-9743 Project: Kafka Issue

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Priority: Blocker (was: Major) > Consumer could catch InconsistentGroupProtocolException during

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Description: The bug was due to an out-of-order handling of the SyncGroupRequest after the

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Description: The bug was due to an out-of-order handling of the SyncGroupRequest after the

[jira] [Assigned] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9701: -- Assignee: Boyang Chen > Consumer could catch InconsistentGroupProtocolException during

[jira] [Resolved] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

[ https://issues.apache.org/jira/browse/KAFKA-9727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9727. Resolution: Fixed > Flaky system test StreamsEOSTest.test_failure_and_recovery >

[jira] [Updated] (KAFKA-9705) Config changes should be propagated from Controller in bridge release

[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9705: --- Summary: Config changes should be propagated from Controller in bridge release (was:

[jira] [Reopened] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-8122: Assignee: (was: Matthias J. Sax) > Flaky Test

[jira] [Commented] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062005#comment-17062005 ] Boyang Chen commented on KAFKA-8122: Failed again 

[jira] [Created] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

Boyang Chen created KAFKA-9727: -- Summary: Flaky system test StreamsEOSTest.test_failure_and_recovery Key: KAFKA-9727 URL: https://issues.apache.org/jira/browse/KAFKA-9727 Project: Kafka Issue

[jira] [Commented] (KAFKA-9679) Mock consumer should behave consistent with actual consumer

[ https://issues.apache.org/jira/browse/KAFKA-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059716#comment-17059716 ] Boyang Chen commented on KAFKA-9679: Thanks for taking this up! [~sujayopensource] Yes, the behavior

[jira] [Commented] (KAFKA-9722) Kafka stops consuming messages after error

[ https://issues.apache.org/jira/browse/KAFKA-9722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059444#comment-17059444 ] Boyang Chen commented on KAFKA-9722: Could you summarize the error in your description, and share the

[jira] [Assigned] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9568: -- Assignee: Sophie Blee-Goldman > Kstreams APPLICATION_SERVER_CONFIG is not updated with static

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