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

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

[jira] [Commented] (KAFKA-8483) Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error

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

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856233#comment-16856233 ] Jun Rao commented on KAFKA-7504: [~allenxwang], there is a PR attached to the jira. I guess we just want

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

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856208#comment-16856208 ] Guozhang Wang commented on KAFKA-8450: -- SGTM -> Sounds good to me. > Augment processed in

[jira] [Created] (KAFKA-8484) ProducerId reset can cause IllegalStateException

Jason Gustafson created KAFKA-8484: -- Summary: ProducerId reset can cause IllegalStateException Key: KAFKA-8484 URL: https://issues.apache.org/jira/browse/KAFKA-8484 Project: Kafka Issue

[jira] [Updated] (KAFKA-7565) NPE in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7565: --- Fix Version/s: (was: 2.3.0) > NPE in KafkaConsumer > > >

[jira] [Updated] (KAFKA-4332) kafka.api.UserQuotaTest.testThrottledProducerConsumer transient unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-4332: --- Fix Version/s: (was: 2.3.0) > kafka.api.UserQuotaTest.testThrottledProducerConsumer

[jira] [Updated] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7991: --- Fix Version/s: (was: 2.3.0) > Add StreamsUpgradeTest for 2.2 release >

[jira] [Updated] (KAFKA-8123) Flaky Test RequestQuotaTest#testResponseThrottleTimeWhenBothProduceAndRequestQuotasViolated

[ https://issues.apache.org/jira/browse/KAFKA-8123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8123: --- Fix Version/s: (was: 2.3.0) > Flaky Test >

[jira] [Updated] (KAFKA-8483) Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error

[ https://issues.apache.org/jira/browse/KAFKA-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8483: --- Description: The idempotent producer attempts to detect spurious UNKNOWN_PRODUCER_ID errors

[jira] [Created] (KAFKA-8483) Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error

Jason Gustafson created KAFKA-8483: -- Summary: Possible reordering of messages by producer after UNKNOWN_PRODUCER_ID error Key: KAFKA-8483 URL: https://issues.apache.org/jira/browse/KAFKA-8483

[jira] [Created] (KAFKA-8482) alterReplicaLogDirs should be better documented

Colin P. McCabe created KAFKA-8482: -- Summary: alterReplicaLogDirs should be better documented Key: KAFKA-8482 URL: https://issues.apache.org/jira/browse/KAFKA-8482 Project: Kafka Issue

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856171#comment-16856171 ] Matthias J. Sax commented on KAFKA-8455: Thanks [~cemozen]. [~suryateja...@gmail.com], you can

[jira] [Updated] (KAFKA-8119) KafkaConfig listener accessors may fail during dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8119: --- Fix Version/s: (was: 2.3.0) > KafkaConfig listener accessors may fail during dynamic

[jira] [Updated] (KAFKA-8073) Transient failure in kafka.api.UserQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8073: --- Fix Version/s: (was: 2.3.0) 2.4.0 > Transient failure in

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7932: --- Fix Version/s: (was: 2.3.0) 2.4.0 > Streams needs to handle new

[jira] [Updated] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-6078: --- Priority: Major (was: Critical) Fix Version/s: (was: 2.3.0)

[jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5722: --- Fix Version/s: (was: 2.3.0) 2.4.0 > Refactor ConfigCommand to use the

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5453: --- Fix Version/s: (was: 2.3.0) 2.4.0 Moving out of 2.3 in preparation

[jira] [Updated] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-2933: --- Fix Version/s: (was: 2.3.0) > Failure in

[jira] [Updated] (KAFKA-8286) KIP-460 Admin Leader Election RPC

[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Updated] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8263: --- Fix Version/s: (was: 2.3.0) 2.4.0 > Flaky Test

[jira] [Updated] (KAFKA-8395) Add an ability to backup log segment files on truncation

[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8395: --- Fix Version/s: (was: 2.2.2) (was: 2.3.0) > Add an ability to

[jira] [Updated] (KAFKA-8395) Add an ability to backup log segment files on truncation

[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8395: --- Labels: needs-kip (was: ) > Add an ability to backup log segment files on truncation >

[jira] [Resolved] (KAFKA-8449) Restart task on reconfiguration under incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-8449. Resolution: Fixed > Restart task on reconfiguration under incremental cooperative

[jira] [Updated] (KAFKA-8447) New Metric to Measure Number of Tasks on a Connector

[ https://issues.apache.org/jira/browse/KAFKA-8447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8447: --- Component/s: KafkaConnect > New Metric to Measure Number of Tasks on a Connector >

[jira] [Commented] (KAFKA-8395) Add an ability to backup log segment files on truncation

[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856128#comment-16856128 ] Michael Axiak commented on KAFKA-8395: -- Hey [~hachikuji] I was wondering if you could look and/or

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856127#comment-16856127 ] ASF GitHub Bot commented on KAFKA-4893: --- gwenshap commented on pull request #6869: KAFKA-4893: Fix

[jira] [Updated] (KAFKA-8384) Write integration tests for leader election command

[ https://issues.apache.org/jira/browse/KAFKA-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8384: -- Description: Add integration tests for leader election command. Some

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

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856123#comment-16856123 ] SuryaTeja Duggi commented on KAFKA-8450: Sorry didn't get that.    > Augment processed in

[jira] [Resolved] (KAFKA-8385) Fix leader election RPC for all partition so that only partition that had elections are returned

[ https://issues.apache.org/jira/browse/KAFKA-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio resolved KAFKA-8385. --- Resolution: Fixed We ended up implementing this on the original PR:

[jira] [Commented] (KAFKA-8384) Write integration tests for leader election command

[ https://issues.apache.org/jira/browse/KAFKA-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856121#comment-16856121 ] ASF GitHub Bot commented on KAFKA-8384: --- jsancio commented on pull request #6880: KAFKA-8384:

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

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856118#comment-16856118 ] Guozhang Wang commented on KAFKA-8450: -- That SGTM. > Augment processed in MockProcessor as

[jira] [Updated] (KAFKA-8286) KIP-460 Admin Leader Election RPC

[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Created] (KAFKA-8481) Clients may fetch incomplete set of topic partitions just after topic is created

Anna Povzner created KAFKA-8481: --- Summary: Clients may fetch incomplete set of topic partitions just after topic is created Key: KAFKA-8481 URL: https://issues.apache.org/jira/browse/KAFKA-8481

[jira] [Created] (KAFKA-8480) Clients may fetch incomplete set of topic partitions during cluster startup

Anna Povzner created KAFKA-8480: --- Summary: Clients may fetch incomplete set of topic partitions during cluster startup Key: KAFKA-8480 URL: https://issues.apache.org/jira/browse/KAFKA-8480 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856049#comment-16856049 ] SuryaTeja Duggi commented on KAFKA-8450: [~guozhang] I am thinking of using  KeyValueTimestamp

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856005#comment-16856005 ] SuryaTeja Duggi commented on KAFKA-8455: [~cemozen] KIP you mean.  > Add NothingSerde to Serdes

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855988#comment-16855988 ] Cem Ozen commented on KAFKA-8455: - Thanks [~mjsax] and [~suryateja...@gmail.com], I had already started

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

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SuryaTeja Duggi reassigned KAFKA-8450: -- Assignee: SuryaTeja Duggi > Augment processed in MockProcessor as

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855976#comment-16855976 ] SuryaTeja Duggi commented on KAFKA-8455: [~mjsax] Thank you could you please assign some ticket

[jira] [Assigned] (KAFKA-8477) Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2

[ https://issues.apache.org/jira/browse/KAFKA-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur reassigned KAFKA-8477: --- Assignee: David Arthur > Cannot consume and request metadata for __consumer_offsets topic

[jira] [Assigned] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cem Ozen reassigned KAFKA-8455: --- Assignee: Cem Ozen > Add NothingSerde to Serdes > -- > >

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855963#comment-16855963 ] Matthias J. Sax commented on KAFKA-8455: [~suryateja...@gmail.com] seems that [~cemozen] also

[jira] [Commented] (KAFKA-8478) Poll for more records before forced processing

[ https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855957#comment-16855957 ] Sophie Blee-Goldman commented on KAFKA-8478: Also related to KAFKA-7458 > Poll for more

[jira] [Commented] (KAFKA-8477) Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2

[ https://issues.apache.org/jira/browse/KAFKA-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855954#comment-16855954 ] David Arthur commented on KAFKA-8477: - Thanks for the report [~mikemintz]. Is is possible to see some

[jira] [Commented] (KAFKA-8455) Add NothingSerde to Serdes

[ https://issues.apache.org/jira/browse/KAFKA-8455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855933#comment-16855933 ] SuryaTeja Duggi commented on KAFKA-8455: Hi [~vvcephei]  I am unable to assign ticket to self >

[jira] [Updated] (KAFKA-8479) kafka-topics does not allow client config settings using "--config"

[ https://issues.apache.org/jira/browse/KAFKA-8479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yeva Byzek updated KAFKA-8479: -- Description: *Problem*: {{kafka-topics}} argument {{--config}} is used for setting topic config

[jira] [Created] (KAFKA-8479) kafka-topics does not allow client config settings using "--config"

Yeva Byzek created KAFKA-8479: - Summary: kafka-topics does not allow client config settings using "--config" Key: KAFKA-8479 URL: https://issues.apache.org/jira/browse/KAFKA-8479 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855863#comment-16855863 ] Utkarsh commented on KAFKA-8450: Hi [~guozhang] I would like to work on this one. Do you have any other

[jira] [Assigned] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-4893: -- Assignee: Colin P. McCabe (was: Vahid Hashemian) > async topic deletion conflicts

[jira] [Commented] (KAFKA-8478) Poll for more records before forced processing

[ https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855844#comment-16855844 ] John Roesler commented on KAFKA-8478: - Not sure if this is related to KAFKA-8315, but it seems

[jira] [Created] (KAFKA-8478) Poll for more records before forced processing

John Roesler created KAFKA-8478: --- Summary: Poll for more records before forced processing Key: KAFKA-8478 URL: https://issues.apache.org/jira/browse/KAFKA-8478 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7504) Broker performance degradation caused by call of sendfile reading disk in network thread

[ https://issues.apache.org/jira/browse/KAFKA-7504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855818#comment-16855818 ] Stanislav Kozlovski commented on KAFKA-7504: [~kawamuray] this is great work, thanks for

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855662#comment-16855662 ] ASF GitHub Bot commented on KAFKA-5998: --- bbejeck commented on pull request #6846: KAFKA-5998:

[jira] [Commented] (KAFKA-8470) State change logs should not be in TRACE level

[ https://issues.apache.org/jira/browse/KAFKA-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855476#comment-16855476 ] ASF GitHub Bot commented on KAFKA-8470: --- stanislavkozlovski commented on pull request #6878:

[jira] [Assigned] (KAFKA-8470) State change logs should not be in TRACE level

[ https://issues.apache.org/jira/browse/KAFKA-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-8470: -- Assignee: Stanislav Kozlovski > State change logs should not be in TRACE