[jira] [Commented] (KAFKA-8877) Race condition on partition counter

[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923313#comment-16923313 ] huxihx commented on KAFKA-8877: --- Seems `nextValue` is already removed by

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923359#comment-16923359 ] Bruno Cadonna commented on KAFKA-7994: -- I applied PR #6694 on the example I presented in my comment

[jira] [Comment Edited] (KAFKA-8877) Race condition on partition counter

[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923379#comment-16923379 ] Oleg Kuznetsov edited comment on KAFKA-8877 at 9/5/19 12:36 PM:

[jira] [Commented] (KAFKA-8877) Race condition on partition counter

[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923379#comment-16923379 ] Oleg Kuznetsov commented on KAFKA-8877: --- [~huxi_2b] Yes, you are right.   But looks like the

[jira] [Commented] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

[ https://issues.apache.org/jira/browse/KAFKA-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923713#comment-16923713 ] ASF GitHub Bot commented on KAFKA-8878: --- cpettitt-confluent commented on pull request #7302:

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923604#comment-16923604 ] Matthias J. Sax commented on KAFKA-8264:

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923608#comment-16923608 ] Matthias J. Sax commented on KAFKA-8264:

[jira] [Resolved] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3

[ https://issues.apache.org/jira/browse/KAFKA-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8724. Resolution: Fixed > log cleaner thread dies when attempting to clean a __consumer_offsets

[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

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

[jira] [Created] (KAFKA-8879) GlobalStateUpdateTask uses wrong javaType to deserialize value

Vlad Olevsky created KAFKA-8879: --- Summary: GlobalStateUpdateTask uses wrong javaType to deserialize value Key: KAFKA-8879 URL: https://issues.apache.org/jira/browse/KAFKA-8879 Project: Kafka

[jira] [Assigned] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

[ https://issues.apache.org/jira/browse/KAFKA-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8878: -- Assignee: Chris Pettitt > Flaky Test

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

[ https://issues.apache.org/jira/browse/KAFKA-8800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923611#comment-16923611 ] Matthias J. Sax commented on KAFKA-8800:

[jira] [Commented] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3

[ https://issues.apache.org/jira/browse/KAFKA-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923578#comment-16923578 ] ASF GitHub Bot commented on KAFKA-8724: --- hachikuji commented on pull request #7264: KAFKA-8724;

[jira] [Created] (KAFKA-8878) Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS

Matthias J. Sax created KAFKA-8878: -- Summary: Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS Key: KAFKA-8878 URL: https://issues.apache.org/jira/browse/KAFKA-8878

[jira] [Assigned] (KAFKA-8853) Create sustained connections test for Trogdor

[ https://issues.apache.org/jira/browse/KAFKA-8853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Hendricks reassigned KAFKA-8853: -- Assignee: Scott Hendricks > Create sustained connections test for Trogdor >

[jira] [Updated] (KAFKA-8879) GlobalStateUpdateTask uses wrong javaType to deserialize value

[ https://issues.apache.org/jira/browse/KAFKA-8879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vlad Olevsky updated KAFKA-8879: Description: We read messages from input topic, transform messages

[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] [Updated] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6460: --- Labels: kip newbie++ (was: newbie++) > Add mocks for state stores used in Streams unit

[jira] [Updated] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6460: --- Component/s: (was: unit tests) (was: streams)

[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] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7895: --- Fix Version/s: 2.3.0 > Ktable supress operator emitting more than one record for the same

[jira] [Commented] (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:comment-tabpanel=16923822#comment-16923822 ] ASF GitHub Bot commented on KAFKA-8880: --- guozhangwang commented on pull request #7304: KAFKA-8880:

[jira] [Commented] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923832#comment-16923832 ] ASF GitHub Bot commented on KAFKA-8813: --- soondenana commented on pull request #7305: KAFKA-8813:

[jira] [Commented] (KAFKA-8818) CreatePartitions Request protocol documentation

[ https://issues.apache.org/jira/browse/KAFKA-8818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923907#comment-16923907 ] huxihx commented on KAFKA-8818: --- Why do you think the array here is invalid? It stores the replica

[jira] [Updated] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-1534: --- Labels: flaky-test newbie (was: newbie transient-unit-test-failure) > transient unit test

[jira] [Updated] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-1534: --- Parent: (was: KAFKA-2054) Issue Type: Bug (was: Sub-task) > transient unit test

[jira] [Reopened] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-1534: Assignee: (was: Abhishek Sharma) Failed again: 

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923721#comment-16923721 ] ASF GitHub Bot commented on KAFKA-7149: --- guozhangwang commented on pull request #7185: KAFKA-7149 :

[jira] [Updated] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection

[ https://issues.apache.org/jira/browse/KAFKA-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-1534: --- Component/s: unit tests > transient unit test failure in testBasicPreferredReplicaElection >

[jira] [Commented] (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:comment-tabpanel=16923831#comment-16923831 ] Guozhang Wang commented on KAFKA-8574: -- Sorry for being late on this ticket. I've read through the

[jira] [Resolved] (KAFKA-8879) GlobalStateUpdateTask uses wrong javaType to deserialize value

[ https://issues.apache.org/jira/browse/KAFKA-8879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vlad Olevsky resolved KAFKA-8879. - Resolution: Invalid > GlobalStateUpdateTask uses wrong javaType to deserialize value >

[jira] [Assigned] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7499: -- Assignee: Alaa Zbair > Extend ProductionExceptionHandler to cover serialization

[jira] [Commented] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923794#comment-16923794 ] Matthias J. Sax commented on KAFKA-7499: [~Chilio] – thanks for you interest. I added you to the

[jira] [Resolved] (KAFKA-4729) Stores for kstream-kstream join cannot be in-memory

[ https://issues.apache.org/jira/browse/KAFKA-4729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4729. Resolution: Duplicate > Stores for kstream-kstream join cannot be in-memory >

[jira] [Commented] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923917#comment-16923917 ] huxihx commented on KAFKA-8838: --- Do you use the latest version? I cannot reproduce this problem using 2.3. 

[jira] [Commented] (KAFKA-8857) Config describe should not return isReadOnly=false based on synonyms

[ https://issues.apache.org/jira/browse/KAFKA-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923178#comment-16923178 ] ASF GitHub Bot commented on KAFKA-8857: --- rajinisivaram commented on pull request #7278: KAFKA-8857;

[jira] [Resolved] (KAFKA-8857) Config describe should not return isReadOnly=false based on synonyms

[ https://issues.apache.org/jira/browse/KAFKA-8857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8857. --- Reviewer: Manikumar Resolution: Fixed > Config describe should not return

[jira] [Resolved] (KAFKA-8866) Make Authorizer create/delete exceptions Optional

[ https://issues.apache.org/jira/browse/KAFKA-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8866. --- Reviewer: Ismael Juma Resolution: Fixed > Make Authorizer create/delete exceptions

[jira] [Updated] (KAFKA-8877) Race condition on partition counter

[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-8877: -- Description: In the method:

[jira] [Commented] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline

[ https://issues.apache.org/jira/browse/KAFKA-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923242#comment-16923242 ] ASF GitHub Bot commented on KAFKA-8876: --- huxihx commented on pull request #7300:

[jira] [Assigned] (KAFKA-8876) KafkaBasedLog does not throw exception when some partitions of the topic is offline

[ https://issues.apache.org/jira/browse/KAFKA-8876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-8876: - Assignee: huxihx > KafkaBasedLog does not throw exception when some partitions of the topic is >

[jira] [Updated] (KAFKA-8877) Race condition on partition counter

[ https://issues.apache.org/jira/browse/KAFKA-8877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleg Kuznetsov updated KAFKA-8877: -- Description: In the method:

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923099#comment-16923099 ] Levani Kokhreidze commented on KAFKA-8264: --

[jira] [Created] (KAFKA-8877) Race condition on partition counter

Oleg Kuznetsov created KAFKA-8877: - Summary: Race condition on partition counter Key: KAFKA-8877 URL: https://issues.apache.org/jira/browse/KAFKA-8877 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8866) Make Authorizer create/delete exceptions Optional

[ https://issues.apache.org/jira/browse/KAFKA-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923174#comment-16923174 ] ASF GitHub Bot commented on KAFKA-8866: --- rajinisivaram commented on pull request #7294: KAFKA-8866;