[jira] [Resolved] (KAFKA-9481) Improve TaskMigratedException handling on Stream thread

[ https://issues.apache.org/jira/browse/KAFKA-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9481. -- Fix Version/s: 2.6.0 Resolution: Fixed > Improve TaskMigratedException handling on

[jira] [Resolved] (KAFKA-8910) Incorrect javadoc at KafkaProducer.InterceptorCallback#onCompletion

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

[jira] [Resolved] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9417. -- Resolution: Fixed > Integration test for new EOS model with vanilla Producer and Consumer >

[jira] [Resolved] (KAFKA-9523) Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest

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

[jira] [Resolved] (KAFKA-9505) InternalTopicManager may falls into infinite loop with partially created topics

[ https://issues.apache.org/jira/browse/KAFKA-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9505. -- Fix Version/s: 2.5.0 Resolution: Fixed > InternalTopicManager may falls into infinite

[jira] [Created] (KAFKA-9526) Augment topology description with serdes

Guozhang Wang created KAFKA-9526: Summary: Augment topology description with serdes Key: KAFKA-9526 URL: https://issues.apache.org/jira/browse/KAFKA-9526 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-9177) Pause completed partitions on restore consumer

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

[jira] [Resolved] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8737. -- Assignee: Guozhang Wang (was: Bill Bejeck) Resolution: Duplicate > TaskMigrated

[jira] [Resolved] (KAFKA-9427) StateRestoreListener.onRestoreEnd should report actual message count

[ https://issues.apache.org/jira/browse/KAFKA-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9427. -- Resolution: Fixed This has been fixed as part of KAFKA-9113. >

[jira] [Resolved] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9113. -- Fix Version/s: 2.6.0 Resolution: Fixed This clean is done in trunk (2.6.0) now. >

[jira] [Resolved] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

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

[jira] [Created] (KAFKA-9505) InternalTopicManager may falls into infinite loop with partially created topics

Guozhang Wang created KAFKA-9505: Summary: InternalTopicManager may falls into infinite loop with partially created topics Key: KAFKA-9505 URL: https://issues.apache.org/jira/browse/KAFKA-9505

[jira] [Created] (KAFKA-9481) Improve TaskMigratedException handling on Stream thread

Guozhang Wang created KAFKA-9481: Summary: Improve TaskMigratedException handling on Stream thread Key: KAFKA-9481 URL: https://issues.apache.org/jira/browse/KAFKA-9481 Project: Kafka Issue

[jira] [Created] (KAFKA-9455) Consider using TreeMap for In-memory stores of Streams

Guozhang Wang created KAFKA-9455: Summary: Consider using TreeMap for In-memory stores of Streams Key: KAFKA-9455 URL: https://issues.apache.org/jira/browse/KAFKA-9455 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6212) Kafka Streams - Incorrect partition rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-6212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6212. -- Resolution: Cannot Reproduce > Kafka Streams - Incorrect partition rebalancing >

[jira] [Resolved] (KAFKA-9159) Consumer.endOffsets Throw TimeoutException: Failed to get offsets by times in 30000ms after a leader change

[ https://issues.apache.org/jira/browse/KAFKA-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9159. -- Fix Version/s: 2.5.0 Resolution: Fixed This has been fixed and would be included in the

[jira] [Resolved] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

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

[jira] [Resolved] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

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

[jira] [Resolved] (KAFKA-9384) Loop improvements

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

[jira] [Created] (KAFKA-9382) Allow consumers to commit offset in the middle of a rebalance

Guozhang Wang created KAFKA-9382: Summary: Allow consumers to commit offset in the middle of a rebalance Key: KAFKA-9382 URL: https://issues.apache.org/jira/browse/KAFKA-9382 Project: Kafka

[jira] [Resolved] (KAFKA-9335) java.lang.IllegalArgumentException: Number of partitions must be at least 1.

[ https://issues.apache.org/jira/browse/KAFKA-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9335. -- Resolution: Fixed > java.lang.IllegalArgumentException: Number of partitions must be at least

[jira] [Created] (KAFKA-9361) Consider being restrictive on overloaded commit function with specific partition->offsets

Guozhang Wang created KAFKA-9361: Summary: Consider being restrictive on overloaded commit function with specific partition->offsets Key: KAFKA-9361 URL: https://issues.apache.org/jira/browse/KAFKA-9361

[jira] [Resolved] (KAFKA-8928) Logged producer config does not always match actual config values

[ https://issues.apache.org/jira/browse/KAFKA-8928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8928. -- Fix Version/s: 2.5.0 Resolution: Fixed > Logged producer config does not always match

[jira] [Resolved] (KAFKA-9202) serde in ConsoleConsumer with access to headers

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

[jira] [Resolved] (KAFKA-9277) move all group state transition rules into their states

[ https://issues.apache.org/jira/browse/KAFKA-9277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9277. -- Fix Version/s: 2.5.0 Resolution: Fixed > move all group state transition rules into

[jira] [Resolved] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9173. -- Resolution: Not A Problem > StreamsPartitionAssignor assigns partitions to only one worker >

[jira] [Resolved] (KAFKA-9002) Flaky Test org.apache.kafka.streams.integration.RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenCreated

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

[jira] [Resolved] (KAFKA-4898) Add timeouts to streams integration tests

[ https://issues.apache.org/jira/browse/KAFKA-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4898. -- Resolution: Won't Fix > Add timeouts to streams integration tests >

[jira] [Resolved] (KAFKA-9208) Flaky Test SslAdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9208. -- Assignee: huxihx Resolution: Fixed This is resolved by the PR targeted for KAFKA-9069.

[jira] [Resolved] (KAFKA-9266) KafkaConsumer manual assignment does not reset group assignment

[ https://issues.apache.org/jira/browse/KAFKA-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9266. -- Fix Version/s: 2.3.1 Resolution: Fixed > KafkaConsumer manual assignment does not reset

[jira] [Resolved] (KAFKA-8520) TimeoutException in client side doesn't have stack trace

[ https://issues.apache.org/jira/browse/KAFKA-8520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8520. -- Resolution: Duplicate > TimeoutException in client side doesn't have stack trace >

[jira] [Resolved] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8972. -- Resolution: Fixed > KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback

[jira] [Resolved] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9073. -- Resolution: Fixed > Kafka Streams State stuck in rebalancing after one of the StreamThread >

[jira] [Resolved] (KAFKA-8800) Flaky Test SaslScramSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8800. -- Fix Version/s: (was: 2.5.0) Resolution: Duplicate > Flaky Test >

[jira] [Resolved] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Resolved] (KAFKA-9045) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Resolved] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

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

[jira] [Reopened] (KAFKA-8700) Flaky Test QueryableStateIntegrationTest#queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-8700: -- Re-opening to further investigation cc [~cpettitt-confluent] > Flaky Test

[jira] [Resolved] (KAFKA-8891) invalid assignment protocol java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

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

[jira] [Resolved] (KAFKA-7263) Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null

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

[jira] [Resolved] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

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

[jira] [Resolved] (KAFKA-9039) Optimize replica fetching CPU utilization with large number of partitions

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

[jira] [Resolved] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9032. -- Resolution: Fixed > Serializer is invoked with null when foreignValue=null >

[jira] [Resolved] (KAFKA-5566) Flaky Test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

[ https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5566. -- Fix Version/s: (was: 1.0.0) 2.4.0 Resolution: Fixed > Flaky Test

[jira] [Resolved] (KAFKA-8700) Flaky Test QueryableStateIntegrationTest#queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8700. -- Assignee: Guozhang Wang Resolution: Fixed This is a duplicate of KAFKA-4222. > Flaky

[jira] [Resolved] (KAFKA-4222) Flaky Test QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4222. -- Fix Version/s: (was: 0.11.0.0) 2.4.0 Assignee: Guozhang Wang

[jira] [Resolved] (KAFKA-8942) Document RocksDB metrics

[ https://issues.apache.org/jira/browse/KAFKA-8942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8942. -- Fix Version/s: 2.4.0 Resolution: Fixed Issue resolved by pull request 7490

[jira] [Created] (KAFKA-9039) Optimize replica fetching CPU utilization with large number of partitions

Guozhang Wang created KAFKA-9039: Summary: Optimize replica fetching CPU utilization with large number of partitions Key: KAFKA-9039 URL: https://issues.apache.org/jira/browse/KAFKA-9039 Project:

[jira] [Created] (KAFKA-9033) Change default client-id in consumer / producer to be more meaningful

Guozhang Wang created KAFKA-9033: Summary: Change default client-id in consumer / producer to be more meaningful Key: KAFKA-9033 URL: https://issues.apache.org/jira/browse/KAFKA-9033 Project: Kafka

[jira] [Created] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

Guozhang Wang created KAFKA-9020: Summary: Streams sub-topologies should be sorted by sink -> source relationship Key: KAFKA-9020 URL: https://issues.apache.org/jira/browse/KAFKA-9020 Project: Kafka

[jira] [Created] (KAFKA-8995) Add new metric on broker to illustrate produce request compression percentage

Guozhang Wang created KAFKA-8995: Summary: Add new metric on broker to illustrate produce request compression percentage Key: KAFKA-8995 URL: https://issues.apache.org/jira/browse/KAFKA-8995 Project:

[jira] [Resolved] (KAFKA-8609) Add consumer metrics for rebalances (part 9)

[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8609. -- Resolution: Fixed > Add consumer metrics for rebalances (part 9) >

[jira] [Resolved] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster

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

[jira] [Resolved] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8319. -- Fix Version/s: 2.4.0 Assignee: Guozhang Wang (was: Bill Bejeck) Resolution:

[jira] [Resolved] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

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

[jira] [Created] (KAFKA-8940) Flaky SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

Guozhang Wang created KAFKA-8940: Summary: Flaky SmokeTestDriverIntegrationTest.shouldWorkWithRebalance Key: KAFKA-8940 URL: https://issues.apache.org/jira/browse/KAFKA-8940 Project: Kafka

[jira] [Resolved] (KAFKA-8086) Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead

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

[jira] [Resolved] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs

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

[jira] [Reopened] (KAFKA-8319) Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory

[ https://issues.apache.org/jira/browse/KAFKA-8319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-8319: -- > Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory >

[jira] [Created] (KAFKA-8925) Flaky Test kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInProduce

Guozhang Wang created KAFKA-8925: Summary: Flaky Test kafka.api.AuthorizerIntegrationTest.testIdempotentProducerNoIdempotentWriteAclInProduce Key: KAFKA-8925 URL: https://issues.apache.org/jira/browse/KAFKA-8925

[jira] [Resolved] (KAFKA-8919) Flaky Test kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess

[ https://issues.apache.org/jira/browse/KAFKA-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8919. -- Resolution: Fixed Realize it is fixed as part of polling (1L) in

[jira] [Created] (KAFKA-8919) Flaky Test kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess

Guozhang Wang created KAFKA-8919: Summary: Flaky Test kafka.api.AuthorizerIntegrationTest.testSimpleConsumeWithOffsetLookupAndNoGroupAccess Key: KAFKA-8919 URL: https://issues.apache.org/jira/browse/KAFKA-8919

[jira] [Created] (KAFKA-8918) Flaky Test org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskCancellation

Guozhang Wang created KAFKA-8918: Summary: Flaky Test org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskCancellation Key: KAFKA-8918 URL: https://issues.apache.org/jira/browse/KAFKA-8918

[jira] [Resolved] (KAFKA-8755) Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store

[ https://issues.apache.org/jira/browse/KAFKA-8755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8755. -- Resolution: Fixed > Stand-by Task of an Optimized Source Table Does Not Write Anything to its

[jira] [Resolved] (KAFKA-8355) Add static membership to Range assignor

[ https://issues.apache.org/jira/browse/KAFKA-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8355. -- Fix Version/s: 2.4.0 Resolution: Fixed > Add static membership to Range assignor >

[jira] [Resolved] (KAFKA-8817) Flaky Test KafkaProducerTest.testCloseIsForcedOnPendingAddOffsetRequest

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

[jira] [Resolved] (KAFKA-8889) Root cause is lost for FetchSessionHandler.handleError

[ https://issues.apache.org/jira/browse/KAFKA-8889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8889. -- Resolution: Fixed > Root cause is lost for FetchSessionHandler.handleError >

[jira] [Created] (KAFKA-8880) Augment Consumer.committed(partition) to allow multiple partitions

Guozhang Wang created KAFKA-8880: Summary: Augment Consumer.committed(partition) to allow multiple partitions Key: KAFKA-8880 URL: https://issues.apache.org/jira/browse/KAFKA-8880 Project: Kafka

[jira] [Resolved] (KAFKA-8793) StickyTaskAssignor throws java.lang.ArithmeticException

[ https://issues.apache.org/jira/browse/KAFKA-8793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8793. -- Resolution: Not A Problem > StickyTaskAssignor throws java.lang.ArithmeticException >

[jira] [Created] (KAFKA-8854) Optimize bulk loading of RocksDB during state restoration of Streams

Guozhang Wang created KAFKA-8854: Summary: Optimize bulk loading of RocksDB during state restoration of Streams Key: KAFKA-8854 URL: https://issues.apache.org/jira/browse/KAFKA-8854 Project: Kafka

[jira] [Resolved] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8412. -- Resolution: Fixed > Still a nullpointer exception thrown on shutdown while flushing before >

[jira] [Resolved] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4600. -- Resolution: Fixed > Consumer proceeds on when ConsumerRebalanceListener fails >

[jira] [Resolved] (KAFKA-8493) Add PartitionsLost API in RebalanceListener (part 3)

[ https://issues.apache.org/jira/browse/KAFKA-8493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8493. -- Resolution: Fixed Fix Version/s: 2.4.0 > Add PartitionsLost API in RebalanceListener

[jira] [Resolved] (KAFKA-8704) Add PartitionAssignor adapter for backwards compatibility

[ https://issues.apache.org/jira/browse/KAFKA-8704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8704. -- Resolution: Fixed Fix Version/s: 2.4.0 > Add PartitionAssignor adapter for backwards

[jira] [Created] (KAFKA-8729) Augment ProduceResponse error messaging for specific culprit records

Guozhang Wang created KAFKA-8729: Summary: Augment ProduceResponse error messaging for specific culprit records Key: KAFKA-8729 URL: https://issues.apache.org/jira/browse/KAFKA-8729 Project: Kafka

[jira] [Resolved] (KAFKA-8675) "Main" consumers are not unsubsribed on KafkaStreams.close()

[ https://issues.apache.org/jira/browse/KAFKA-8675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8675. -- Resolution: Not A Problem > "Main" consumers are not unsubsribed on KafkaStreams.close() >

[jira] [Resolved] (KAFKA-8392) Kafka broker leaks metric when partition leader moves to another node.

[ https://issues.apache.org/jira/browse/KAFKA-8392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8392. -- Resolution: Fixed Fix Version/s: 2.4.0 > Kafka broker leaks metric when partition

[jira] [Resolved] (KAFKA-8218) IllegalStateException while accessing context in Transformer

[ https://issues.apache.org/jira/browse/KAFKA-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8218. -- Resolution: Not A Problem > IllegalStateException while accessing context in Transformer >

[jira] [Resolved] (KAFKA-7176) State store metrics for migrated tasks are not removed

[ https://issues.apache.org/jira/browse/KAFKA-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7176. -- Resolution: Fixed Fix Version/s: 2.3.0 > State store metrics for migrated tasks are not

[jira] [Resolved] (KAFKA-7850) Remove deprecated KStreamTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7850. -- Resolution: Fixed Fix Version/s: 2.3.0 KStreamTestDriver has been removed since 2.3.0

[jira] [Created] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays

Guozhang Wang created KAFKA-8584: Summary: Allow "bytes" type to generated a ByteBuffer rather than byte arrays Key: KAFKA-8584 URL: https://issues.apache.org/jira/browse/KAFKA-8584 Project: Kafka

[jira] [Created] (KAFKA-8581) Augment ProduceResponse error messaging for specific culprit records

Guozhang Wang created KAFKA-8581: Summary: Augment ProduceResponse error messaging for specific culprit records Key: KAFKA-8581 URL: https://issues.apache.org/jira/browse/KAFKA-8581 Project: Kafka

[jira] [Resolved] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8106. -- Resolution: Fixed Fix Version/s: 2.4.0 > Reducing the allocation and copying of

[jira] [Reopened] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-7190: -- Assignee: Guozhang Wang (was: lambdaliu) Reopening this issue since broker would

[jira] [Resolved] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8487. -- Resolution: Fixed Fix Version/s: 2.4.0 > Consumer should not resetGeneration upon

[jira] [Created] (KAFKA-8512) Looking into the Future: Assignor Version

Guozhang Wang created KAFKA-8512: Summary: Looking into the Future: Assignor Version Key: KAFKA-8512 URL: https://issues.apache.org/jira/browse/KAFKA-8512 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8511) Looking into the Future: Heartbeat Communicated Protocol

Guozhang Wang created KAFKA-8511: Summary: Looking into the Future: Heartbeat Communicated Protocol Key: KAFKA-8511 URL: https://issues.apache.org/jira/browse/KAFKA-8511 Project: Kafka Issue

[jira] [Created] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness

Guozhang Wang created KAFKA-8510: Summary: Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness Key: KAFKA-8510 URL: https://issues.apache.org/jira/browse/KAFKA-8510

[jira] [Created] (KAFKA-8496) Add system test for compatibility and upgrade path (part 6)

Guozhang Wang created KAFKA-8496: Summary: Add system test for compatibility and upgrade path (part 6) Key: KAFKA-8496 URL: https://issues.apache.org/jira/browse/KAFKA-8496 Project: Kafka

[jira] [Created] (KAFKA-8495) Make Round-robin / RangeAssignor to be "sticky" (part 5)

Guozhang Wang created KAFKA-8495: Summary: Make Round-robin / RangeAssignor to be "sticky" (part 5) Key: KAFKA-8495 URL: https://issues.apache.org/jira/browse/KAFKA-8495 Project: Kafka Issue

[jira] [Created] (KAFKA-8494) Refactor Consumer#StickyAssignor to support incremental protocol (part 4)

Guozhang Wang created KAFKA-8494: Summary: Refactor Consumer#StickyAssignor to support incremental protocol (part 4) Key: KAFKA-8494 URL: https://issues.apache.org/jira/browse/KAFKA-8494 Project:

[jira] [Created] (KAFKA-8493) Add PartitionsLost API in RebalanceListener

Guozhang Wang created KAFKA-8493: Summary: Add PartitionsLost API in RebalanceListener Key: KAFKA-8493 URL: https://issues.apache.org/jira/browse/KAFKA-8493 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8492) Modify ConsumerCoordinator Algorithm with incremental protocol (part 2)

Guozhang Wang created KAFKA-8492: Summary: Modify ConsumerCoordinator Algorithm with incremental protocol (part 2) Key: KAFKA-8492 URL: https://issues.apache.org/jira/browse/KAFKA-8492 Project: Kafka

[jira] [Created] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1)

Guozhang Wang created KAFKA-8491: Summary: Bump up Consumer Protocol to v2 (part 1) Key: KAFKA-8491 URL: https://issues.apache.org/jira/browse/KAFKA-8491 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

Guozhang Wang created KAFKA-8487: Summary: Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler Key: KAFKA-8487 URL: https://issues.apache.org/jira/browse/KAFKA-8487

[jira] [Resolved] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

[ https://issues.apache.org/jira/browse/KAFKA-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8199. -- Resolution: Fixed > ClassCastException when trying to groupBy after suppress >

[jira] [Created] (KAFKA-8450) Augment processed in MockProcessor as KeyValueAndTimestamp

Guozhang Wang created KAFKA-8450: Summary: Augment processed in MockProcessor as KeyValueAndTimestamp Key: KAFKA-8450 URL: https://issues.apache.org/jira/browse/KAFKA-8450 Project: Kafka

[jira] [Resolved] (KAFKA-8428) Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only

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

[jira] [Created] (KAFKA-8428) Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only

Guozhang Wang created KAFKA-8428: Summary: Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only Key: KAFKA-8428 URL: https://issues.apache.org/jira/browse/KAFKA-8428

[jira] [Created] (KAFKA-8421) Allow consumer.poll() to return data in the middle of rebalance

Guozhang Wang created KAFKA-8421: Summary: Allow consumer.poll() to return data in the middle of rebalance Key: KAFKA-8421 URL: https://issues.apache.org/jira/browse/KAFKA-8421 Project: Kafka

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