[jira] [Commented] (KAFKA-13840) KafkaConsumer is unable to recover connection to group coordinator after commitOffsetsAsync exception

[ https://issues.apache.org/jira/browse/KAFKA-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557572#comment-17557572 ] Guozhang Wang commented on KAFKA-13840: --- [~showuon] I read through the discussions here and I feel

[jira] [Resolved] (KAFKA-13880) DefaultStreamPartitioner may get "stuck" to one partition for unkeyed messages

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

[jira] [Commented] (KAFKA-12639) AbstractCoordinator ignores backoff timeout when joining the consumer group

[ https://issues.apache.org/jira/browse/KAFKA-12639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553811#comment-17553811 ] Guozhang Wang commented on KAFKA-12639: --- This is a separate issue, as `joinGroupIfNeeded` is not

[jira] [Commented] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553806#comment-17553806 ] Guozhang Wang commented on KAFKA-10575: --- I took another look at this ticket while working on

[jira] [Updated] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

[ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10575: -- Labels: (was: new-streams-runtime-should-fix) > StateRestoreListener#onRestoreEnd should

[jira] [Updated] (KAFKA-10199) Separate state restoration into separate threads

[ https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10199: -- Labels: (was: new-streams-runtime-should-fix) > Separate state restoration into separate

[jira] [Updated] (KAFKA-10199) Separate state restoration into separate threads

[ https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10199: -- Labels: new-streams-runtime-should-fix (was: ) > Separate state restoration into separate

[jira] [Commented] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551235#comment-17551235 ] Guozhang Wang commented on KAFKA-13939: --- Once the PR is merged, we can cherry-pick the commit to

[jira] [Updated] (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 ] Guozhang Wang updated KAFKA-13214: -- Labels: new-consumer-threading-should-fix (was: ) > Consumer should not reset group state

[jira] [Updated] (KAFKA-12983) onJoinPrepare is not always invoked before joining the group

[ https://issues.apache.org/jira/browse/KAFKA-12983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12983: -- Labels: new-consumer-threading-should-fix (was: ) > onJoinPrepare is not always invoked

[jira] [Commented] (KAFKA-13939) Memory Leak When Logging Is Disabled In InMemoryTimeOrderedKeyValueBuffer

[ https://issues.apache.org/jira/browse/KAFKA-13939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17545102#comment-17545102 ] Guozhang Wang commented on KAFKA-13939: --- Thanks [~jnewhouse], I looked at the code you pointed it

[jira] [Created] (KAFKA-13934) Consider consolidating TimeWindow / SessionWindow / SlidingWindow

Guozhang Wang created KAFKA-13934: - Summary: Consider consolidating TimeWindow / SessionWindow / SlidingWindow Key: KAFKA-13934 URL: https://issues.apache.org/jira/browse/KAFKA-13934 Project: Kafka

[jira] [Commented] (KAFKA-13621) Resign leader on network partition

[ https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540486#comment-17540486 ] Guozhang Wang commented on KAFKA-13621: --- [~jagsancio] Yes I think with KIP-835 we can augment

[jira] [Resolved] (KAFKA-13745) Flaky kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone

[ https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13745. --- Resolution: Fixed > Flaky >

[jira] [Commented] (KAFKA-13745) Flaky kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone

[ https://issues.apache.org/jira/browse/KAFKA-13745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536959#comment-17536959 ] Guozhang Wang commented on KAFKA-13745: --- Hi [~sagarrao] I'm happy to resolve the ticket now, and

[jira] [Resolved] (KAFKA-13800) Remove force cast of TimeWindowKStreamImpl in tests of https://github.com/apache/kafka/pull/11896

[ https://issues.apache.org/jira/browse/KAFKA-13800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13800. --- Resolution: Fixed > Remove force cast of TimeWindowKStreamImpl in tests of >

[jira] [Resolved] (KAFKA-13746) Flaky kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13746. --- Resolution: Fixed > Flaky >

[jira] [Assigned] (KAFKA-13879) Exponential backoff for reconnect does not work

[ https://issues.apache.org/jira/browse/KAFKA-13879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-13879: - Assignee: Chern Yih Cheah > Exponential backoff for reconnect does not work >

[jira] [Commented] (KAFKA-13877) Flaky RackAwarenessIntegrationTest.shouldDistributeStandbyReplicasOverMultipleClientTags

[ https://issues.apache.org/jira/browse/KAFKA-13877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532480#comment-17532480 ] Guozhang Wang commented on KAFKA-13877: --- Thanks [~lkokhreidze]! > Flaky >

[jira] [Updated] (KAFKA-13877) Flaky RackAwarenessIntegrationTest.shouldDistributeStandbyReplicasOverMultipleClientTags

[ https://issues.apache.org/jira/browse/KAFKA-13877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13877: -- Labels: newbie (was: ) > Flaky >

[jira] [Created] (KAFKA-13877) Flaky RackAwarenessIntegrationTest.shouldDistributeStandbyReplicasOverMultipleClientTags

Guozhang Wang created KAFKA-13877: - Summary: Flaky RackAwarenessIntegrationTest.shouldDistributeStandbyReplicasOverMultipleClientTags Key: KAFKA-13877 URL: https://issues.apache.org/jira/browse/KAFKA-13877

[jira] [Commented] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530569#comment-17530569 ] Guozhang Wang commented on KAFKA-13857: --- Hi [~RivenSun], I think it may be valuable to allow admin

[jira] [Commented] (KAFKA-13857) The listOffsets method of KafkaAdminClient should support returning logEndOffset of topicPartition

[ https://issues.apache.org/jira/browse/KAFKA-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528894#comment-17528894 ] Guozhang Wang commented on KAFKA-13857: --- Hi [~RivenSun] do you have a concrete use case in your

[jira] [Updated] (KAFKA-13824) Pass time object from constructor so that we can mock it if needed

[ https://issues.apache.org/jira/browse/KAFKA-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13824: -- Description: We pass in the {{Time}} object in the StreamThread, which is used to measure

[jira] [Updated] (KAFKA-13824) Pass time object from constructor so that we can mock it if needed

[ https://issues.apache.org/jira/browse/KAFKA-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13824: -- Labels: test (was: ) > Pass time object from constructor so that we can mock it if needed >

[jira] [Updated] (KAFKA-13824) Pass time object from constructor so that we can mock it if needed

[ https://issues.apache.org/jira/browse/KAFKA-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13824: -- Description: (was: In [https://github.com/apache/kafka/pull/11896,] for

[jira] [Resolved] (KAFKA-13647) RocksDb metrics 'number-open-files' is not correct

[ https://issues.apache.org/jira/browse/KAFKA-13647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13647. --- Resolution: Incomplete I resolved the ticket for now as incomplete, since the streams code

[jira] [Created] (KAFKA-13846) Add an overloaded metricOrElseCreate function in Metrics

Guozhang Wang created KAFKA-13846: - Summary: Add an overloaded metricOrElseCreate function in Metrics Key: KAFKA-13846 URL: https://issues.apache.org/jira/browse/KAFKA-13846 Project: Kafka

[jira] [Updated] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13838: -- Labels: new-consumer-threading-should-fix (was: ) > Improve the poll method of

[jira] [Commented] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526071#comment-17526071 ] Guozhang Wang commented on KAFKA-13838: --- Also bringing to [~kirktrue]'s radar. > Improve the poll

[jira] [Assigned] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-13588: - Assignee: Guozhang Wang (was: Sayantanu Dey) > We should consolidate `changelogFor`

[jira] [Commented] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525203#comment-17525203 ] Guozhang Wang commented on KAFKA-13588: --- Thanks [~dsayan] I've merged your PR. We will keep this

[jira] [Updated] (KAFKA-13834) batch drain for nodes might have starving issue

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13834: -- Reviewer: Luke Chen (was: Guozhang Wang) > batch drain for nodes might have starving issue >

[jira] [Commented] (KAFKA-13834) batch drain for nodes might have starving issue

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525181#comment-17525181 ] Guozhang Wang commented on KAFKA-13834: --- [~ruanliang] I've added you to the contributor list and

[jira] [Assigned] (KAFKA-13834) batch drain for nodes might have starving issue

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-13834: - Assignee: ruanliang > batch drain for nodes might have starving issue >

[jira] [Commented] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525174#comment-17525174 ] Guozhang Wang commented on KAFKA-13838: --- I did a quick look, and I think I agree with [~RivenSun]

[jira] [Commented] (KAFKA-13838) Improve the poll method of ConsumerNetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525168#comment-17525168 ] Guozhang Wang commented on KAFKA-13838: --- cc [~hachikuji] as you are working on the threading

[jira] [Updated] (KAFKA-13811) Investigate sliding windows performance

[ https://issues.apache.org/jira/browse/KAFKA-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13811: -- Labels: perfomance (was: ) > Investigate sliding windows performance >

[jira] [Commented] (KAFKA-13768) Transactional producer exits because of expiration in RecordAccumulator

[ https://issues.apache.org/jira/browse/KAFKA-13768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525161#comment-17525161 ] Guozhang Wang commented on KAFKA-13768: --- Hello [~ddrid], I think what you're describing here is

[jira] [Commented] (KAFKA-13765) Describe-consumer admin should not return unstable membership information

[ https://issues.apache.org/jira/browse/KAFKA-13765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525150#comment-17525150 ] Guozhang Wang commented on KAFKA-13765: --- Hello [~rleslie] thanks for the careful thoughts. And I

[jira] [Resolved] (KAFKA-13799) Improve documentation for Kafka zero-copy

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

[jira] [Commented] (KAFKA-13834) Some problems with producers choosing batches of messages to send

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523804#comment-17523804 ] Guozhang Wang commented on KAFKA-13834: --- Also I'm wondering if you can resize the embedded

[jira] [Commented] (KAFKA-13834) Some problems with producers choosing batches of messages to send

[ https://issues.apache.org/jira/browse/KAFKA-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523801#comment-17523801 ] Guozhang Wang commented on KAFKA-13834: --- [~shizhenzhen] Thanks for filing the JIRA ticket. Could

[jira] [Updated] (KAFKA-13773) Data loss after recovery from crash due to full hard disk

[ https://issues.apache.org/jira/browse/KAFKA-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13773: -- Priority: Critical (was: Major) > Data loss after recovery from crash due to full hard disk

[jira] [Updated] (KAFKA-13773) Data loss after recovery from crash due to full hard disk

[ https://issues.apache.org/jira/browse/KAFKA-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13773: -- Component/s: log (was: log cleaner) > Data loss after recovery from

[jira] [Commented] (KAFKA-13799) Improve documentation for Kafka zero-copy

[ https://issues.apache.org/jira/browse/KAFKA-13799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522601#comment-17522601 ] Guozhang Wang commented on KAFKA-13799: --- [~RivenSun] I agree with you assessment. We can update

[jira] [Commented] (KAFKA-8178) KafkaProducer#send(ProducerRecord,Callback) may block for up to 60 seconds

[ https://issues.apache.org/jira/browse/KAFKA-8178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522550#comment-17522550 ] Guozhang Wang commented on KAFKA-8178: -- I think it's fair to update the docs to explicitly state

[jira] [Updated] (KAFKA-10405) Flaky Test org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState

[ https://issues.apache.org/jira/browse/KAFKA-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10405: -- Fix Version/s: 3.3.0 (was: 3.2.0) > Flaky Test >

[jira] [Updated] (KAFKA-10405) Flaky Test org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest.shouldRestoreState

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

[jira] [Commented] (KAFKA-13771) Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512444#comment-17512444 ] Guozhang Wang commented on KAFKA-13771: --- cc [~rsivaram] could you take a look at this ticket when

[jira] [Resolved] (KAFKA-13692) stream thread blocked-time-ns-total metric does not include producer metadata wait time

[ https://issues.apache.org/jira/browse/KAFKA-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13692. --- Fix Version/s: 3.3.0 (was: 3.2.0) Resolution: Fixed > stream

[jira] [Assigned] (KAFKA-13692) stream thread blocked-time-ns-total metric does not include producer metadata wait time

[ https://issues.apache.org/jira/browse/KAFKA-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-13692: - Assignee: Rohan Desai > stream thread blocked-time-ns-total metric does not include

[jira] [Updated] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13689: -- Fix Version/s: 3.3.0 (was: 3.2.0) > AbstractConfig log print

[jira] [Commented] (KAFKA-13766) Use `max.poll.interval.ms` as the timeout during complete-rebalance phase

[ https://issues.apache.org/jira/browse/KAFKA-13766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511534#comment-17511534 ] Guozhang Wang commented on KAFKA-13766: --- cc [~dajac] > Use `max.poll.interval.ms` as the timeout

[jira] [Created] (KAFKA-13766) Use `max.poll.interval.ms` as the timeout during complete-rebalance phase

Guozhang Wang created KAFKA-13766: - Summary: Use `max.poll.interval.ms` as the timeout during complete-rebalance phase Key: KAFKA-13766 URL: https://issues.apache.org/jira/browse/KAFKA-13766 Project:

[jira] [Created] (KAFKA-13765) Describe-consumer admin should not return unstable membership information

Guozhang Wang created KAFKA-13765: - Summary: Describe-consumer admin should not return unstable membership information Key: KAFKA-13765 URL: https://issues.apache.org/jira/browse/KAFKA-13765 Project:

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511522#comment-17511522 ] Guozhang Wang commented on KAFKA-13689: --- Hi [~RivenSun] I think I agree with you on the general

[jira] [Comment Edited] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510767#comment-17510767 ] Guozhang Wang edited comment on KAFKA-13689 at 3/22/22, 5:14 PM: - Okay I

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510767#comment-17510767 ] Guozhang Wang commented on KAFKA-13689: --- Okay I think we are really on the same page here, just

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510209#comment-17510209 ] Guozhang Wang commented on KAFKA-13689: --- Hello [~RivenSun] I agree with you except some pondering

[jira] [Resolved] (KAFKA-13728) PushHttpMetricsReporter no longer pushes metrics when network failure is recovered.

[ https://issues.apache.org/jira/browse/KAFKA-13728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13728. --- Fix Version/s: 3.2.0 Resolution: Fixed > PushHttpMetricsReporter no longer pushes

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509372#comment-17509372 ] Guozhang Wang commented on KAFKA-13689: --- > So for these unKnown configs, they will never appear in

[jira] [Commented] (KAFKA-13689) AbstractConfig log print information is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509357#comment-17509357 ] Guozhang Wang commented on KAFKA-13689: --- Hi, I think we can first revisit the meaningfulness of

[jira] [Created] (KAFKA-13746) Flaky kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed

Guozhang Wang created KAFKA-13746: - Summary: Flaky kafka.admin.TopicCommandIntegrationTest.testDescribeUnderMinIsrPartitionsMixed Key: KAFKA-13746 URL: https://issues.apache.org/jira/browse/KAFKA-13746

[jira] [Created] (KAFKA-13745) Flaky kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone

Guozhang Wang created KAFKA-13745: - Summary: Flaky kafka.network.SocketServerTest.testNoOpActionResponseWithThrottledChannelWhereThrottlingAlreadyDone Key: KAFKA-13745 URL:

[jira] [Updated] (KAFKA-6089) Transient failure in kafka.network.SocketServerTest.configureNewConnectionException

[ https://issues.apache.org/jira/browse/KAFKA-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6089: - Fix Version/s: 3.2.0 > Transient failure in >

[jira] [Updated] (KAFKA-13584) Fix `kafka.network.SocketServerTest.testUnmuteChannelWithBufferedReceives` flaky test

[ https://issues.apache.org/jira/browse/KAFKA-13584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13584: -- Priority: Blocker (was: Major) > Fix

[jira] [Updated] (KAFKA-13584) Fix `kafka.network.SocketServerTest.testUnmuteChannelWithBufferedReceives` flaky test

[ https://issues.apache.org/jira/browse/KAFKA-13584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13584: -- Fix Version/s: 3.2.0 > Fix

[jira] [Updated] (KAFKA-13584) Fix `kafka.network.SocketServerTest.testUnmuteChannelWithBufferedReceives` flaky test

[ https://issues.apache.org/jira/browse/KAFKA-13584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13584: -- Issue Type: Bug (was: Improvement) > Fix

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

[ https://issues.apache.org/jira/browse/KAFKA-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8785: - Fix Version/s: 3.2.0 > Flakey test LeaderElectionCommandTest#testPathToJsonFile >

[jira] [Updated] (KAFKA-13737) Flaky kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-13737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13737: -- Priority: Blocker (was: Major) > Flaky

[jira] [Updated] (KAFKA-13737) Flaky kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection

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

[jira] [Updated] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13736: -- Priority: Blocker (was: Major) > Flaky

[jira] [Updated] (KAFKA-13735) Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

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

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

[ https://issues.apache.org/jira/browse/KAFKA-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8785: - Priority: Blocker (was: Major) > Flakey test LeaderElectionCommandTest#testPathToJsonFile >

[jira] [Updated] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

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

[jira] [Updated] (KAFKA-13735) Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13735: -- Priority: Blocker (was: Major) > Flaky

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

[ https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8541: - Fix Version/s: 3.2.0 > Flakey test LeaderElectionCommandTest#testTopicPartition >

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

[ https://issues.apache.org/jira/browse/KAFKA-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8541: - Priority: Blocker (was: Major) > Flakey test LeaderElectionCommandTest#testTopicPartition >

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7957: - Priority: Blocker (was: Critical) > Flaky Test

[jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate

[ https://issues.apache.org/jira/browse/KAFKA-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7957: - Fix Version/s: 3.2.0 > Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate >

[jira] [Updated] (KAFKA-13672) Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()

[ https://issues.apache.org/jira/browse/KAFKA-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13672: -- Fix Version/s: 3.2.0 > Flaky test >

[jira] [Updated] (KAFKA-13672) Flaky test kafka.server.DynamicBrokerReconfigurationTest.testThreadPoolResize()

[ https://issues.apache.org/jira/browse/KAFKA-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13672: -- Priority: Blocker (was: Major) > Flaky test >

[jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8280: - Priority: Blocker (was: Major) > Flaky Test

[jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

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

[jira] [Updated] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

[ https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6527: - Priority: Blocker (was: Major) > Transient failure in

[jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13421: -- Fix Version/s: 3.2.0 > Fix >

[jira] [Updated] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

[ https://issues.apache.org/jira/browse/KAFKA-6527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6527: - Fix Version/s: 3.2.0 > Transient failure in

[jira] [Updated] (KAFKA-7540) Flaky Test ConsumerBounceTest#testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7540: - Fix Version/s: 3.2.0 > Flaky Test ConsumerBounceTest#testClose >

[jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13421: -- Priority: Blocker (was: Major) > Fix >

[jira] [Updated] (KAFKA-7540) Flaky Test ConsumerBounceTest#testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7540: - Priority: Blocker (was: Critical) > Flaky Test ConsumerBounceTest#testClose >

[jira] [Updated] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12495: -- Priority: Blocker (was: Major) > Unbalanced connectors/tasks distribution will happen in

[jira] [Updated] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8391: - Priority: Blocker (was: Critical) > Flaky Test

[jira] [Updated] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8391: - Fix Version/s: 3.2.0 (was: 2.3.2) (was: 2.6.0)

[jira] [Created] (KAFKA-13737) Flaky kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection

Guozhang Wang created KAFKA-13737: - Summary: Flaky kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection Key: KAFKA-13737 URL: https://issues.apache.org/jira/browse/KAFKA-13737 Project:

[jira] [Reopened] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-13736: --- > Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives >

[jira] [Resolved] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

[ https://issues.apache.org/jira/browse/KAFKA-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-13736. --- Resolution: Duplicate > Flaky

[jira] [Created] (KAFKA-13736) Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives

Guozhang Wang created KAFKA-13736: - Summary: Flaky kafka.network.SocketServerTest.closingChannelWithBufferedReceives Key: KAFKA-13736 URL: https://issues.apache.org/jira/browse/KAFKA-13736 Project:

[jira] [Created] (KAFKA-13735) Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives

Guozhang Wang created KAFKA-13735: - Summary: Flaky kafka.network.SocketServerTest.remoteCloseWithoutBufferedReceives Key: KAFKA-13735 URL: https://issues.apache.org/jira/browse/KAFKA-13735 Project:

[jira] [Reopened] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-13421: --- Re-opening this ticket since the test is still failing. > Fix >

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