[jira] [Comment Edited] (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=16858934#comment-16858934 ] Allen Wang edited comment on KAFKA-7504 at 6/8/19 2:26 AM: --- We tested this

[jira] [Commented] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

[ https://issues.apache.org/jira/browse/KAFKA-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859077#comment-16859077 ] ASF GitHub Bot commented on KAFKA-8513: --- sekikn commented on pull request #6909: KAFKA-8513: Add

[jira] [Created] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

Kengo Seki created KAFKA-8513: - Summary: Add kafka-streams-application-reset.bat for Windows platform Key: KAFKA-8513 URL: https://issues.apache.org/jira/browse/KAFKA-8513 Project: Kafka Issue

[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=16859064#comment-16859064 ] Allen Wang commented on KAFKA-7504: --- [~junrao] Yes I measured the total response time for produce

[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=16859041#comment-16859041 ] Mike Mintz commented on KAFKA-8477: --- Hi [~mumrah], unfortunately I'm unable to reproduce this again

[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=16859031#comment-16859031 ] Jun Rao commented on KAFKA-7504: [~allenxwang], thanks for doing the test and sharing the results. Your

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

[ https://issues.apache.org/jira/browse/KAFKA-8495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859012#comment-16859012 ] Guozhang Wang commented on KAFKA-8495: -- If we decide round-robin / range would not support

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

[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859010#comment-16859010 ] Guozhang Wang commented on KAFKA-8494: -- This would also involve making this assignor to be the

[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] [Updated] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8510: - Summary: Update StreamsPartitionAssignor to use the built-in owned partitions to achieve

[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] [Commented] (KAFKA-8499) Ducker missing java commands in path for ducker user on openjdk docker images

[ https://issues.apache.org/jira/browse/KAFKA-8499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858999#comment-16858999 ] ASF GitHub Bot commented on KAFKA-8499: --- cmccabe commented on pull request #6898: KAFKA-8499:

[jira] [Updated] (KAFKA-8331) Add system test for enabling static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8331: --- Fix Version/s: 2.4.0 > Add system test for enabling static membership on KStream >

[jira] [Updated] (KAFKA-8331) Add system test for enabling static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8331: --- Component/s: streams > Add system test for enabling static membership on KStream >

[jira] [Updated] (KAFKA-8331) Add system test for enabling static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8331: --- Affects Version/s: 2.4.0 > Add system test for enabling static membership on KStream >

[jira] [Resolved] (KAFKA-8331) Add system test for enabling static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8331. Resolution: Fixed > Add system test for enabling static membership on KStream >

[jira] [Commented] (KAFKA-8331) Add system test for enabling static membership on KStream

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

[jira] [Commented] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration

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

[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=16858934#comment-16858934 ] Allen Wang commented on KAFKA-7504: --- We tested this patch in the following setting:   Brokers: 6

[jira] [Commented] (KAFKA-8507) Support --bootstrap-server in all command line tools

[ https://issues.apache.org/jira/browse/KAFKA-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858904#comment-16858904 ] Ismael Juma commented on KAFKA-8507: There's a PR for this. > Support --bootstrap-server in all

[jira] [Updated] (KAFKA-8509) Add downgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-8509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8509: --- Component/s: system tests > Add downgrade system tests > -- > >

[jira] [Created] (KAFKA-8509) Add downgrade system tests

Jason Gustafson created KAFKA-8509: -- Summary: Add downgrade system tests Key: KAFKA-8509 URL: https://issues.apache.org/jira/browse/KAFKA-8509 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8508) saslClient failed to initialize properly: it's null.

Caroline Liu created KAFKA-8508: --- Summary: saslClient failed to initialize properly: it's null. Key: KAFKA-8508 URL: https://issues.apache.org/jira/browse/KAFKA-8508 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-8003) Flaky Test TransactionsTest #testFencingOnTransactionExpiration

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

[jira] [Updated] (KAFKA-8507) Support --bootstrap-server in all command line tools

[ https://issues.apache.org/jira/browse/KAFKA-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8507: --- Description: This is a unambitious initial move toward standardizing the command line tools.

[jira] [Created] (KAFKA-8507) Support --bootstrap-server in all command line tools

Jason Gustafson created KAFKA-8507: -- Summary: Support --bootstrap-server in all command line tools Key: KAFKA-8507 URL: https://issues.apache.org/jira/browse/KAFKA-8507 Project: Kafka Issue

[jira] [Issue Comment Deleted] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

[ https://issues.apache.org/jira/browse/KAFKA-8506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav updated KAFKA-8506: -- Comment: was deleted (was: Properties props = {color:#80}new {color}Properties();

[jira] [Commented] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

[ https://issues.apache.org/jira/browse/KAFKA-8506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858771#comment-16858771 ] Gaurav commented on KAFKA-8506: --- Properties props = {color:#80}new {color}Properties();

[jira] [Commented] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

[ https://issues.apache.org/jira/browse/KAFKA-8506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858774#comment-16858774 ] Gaurav commented on KAFKA-8506: --- its kafka consumer > Kafka Consumer broker never stops on connection

[jira] [Commented] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

[ https://issues.apache.org/jira/browse/KAFKA-8506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858766#comment-16858766 ] Boyang Chen commented on KAFKA-8506: Why broker calles `consumer.poll`? > Kafka Consumer broker

[jira] [Created] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

Gaurav created KAFKA-8506: - Summary: Kafka Consumer broker never stops on connection failure Key: KAFKA-8506 URL: https://issues.apache.org/jira/browse/KAFKA-8506 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-8501) Remove key and value from exception message

[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carlos Manuel Duclos Vergara reassigned KAFKA-8501: --- Assignee: Carlos Manuel Duclos Vergara > Remove key and

[jira] [Commented] (KAFKA-8501) Remove key and value from exception message

[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858626#comment-16858626 ] ASF GitHub Bot commented on KAFKA-8501: --- carlosduclos commented on pull request #6904: KAFKA-8501:

[jira] [Created] (KAFKA-8505) Limit the maximum number of connections per ip client ID

Igor Soarez created KAFKA-8505: -- Summary: Limit the maximum number of connections per ip client ID Key: KAFKA-8505 URL: https://issues.apache.org/jira/browse/KAFKA-8505 Project: Kafka Issue

[jira] [Commented] (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:comment-tabpanel=16858616#comment-16858616 ] Andrew Olson commented on KAFKA-8421: - It would be helpful to design and build a stress test harness

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

[ https://issues.apache.org/jira/browse/KAFKA-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858518#comment-16858518 ] Carlos Manuel Duclos Vergara commented on KAFKA-8482: - Looking at the code, it seems

[jira] [Commented] (KAFKA-7911) Add Timezone Support for Windowed Aggregations

[ https://issues.apache.org/jira/browse/KAFKA-7911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858452#comment-16858452 ] Mehmet Salgar commented on KAFKA-7911: -- Hi,   I have the same problem in my Project and I tried to

[jira] [Created] (KAFKA-8504) Suppressed do not emit with TimeWindows

Simone created KAFKA-8504: - Summary: Suppressed do not emit with TimeWindows Key: KAFKA-8504 URL: https://issues.apache.org/jira/browse/KAFKA-8504 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8501) Remove key and value from exception message

[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858390#comment-16858390 ] Carlos Manuel Duclos Vergara commented on KAFKA-8501: - I cannot create a PR so here's

[jira] [Comment Edited] (KAFKA-8485) Kafka connect worker does not respond/function when kafka broker goes down.

[ https://issues.apache.org/jira/browse/KAFKA-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858366#comment-16858366 ] kaushik srinivas edited comment on KAFKA-8485 at 6/7/19 7:47 AM: - Hi

[jira] [Updated] (KAFKA-8485) Kafka connect worker does not respond/function when kafka broker goes down.

[ https://issues.apache.org/jira/browse/KAFKA-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaushik srinivas updated KAFKA-8485: Summary: Kafka connect worker does not respond/function when kafka broker goes down.

[jira] [Commented] (KAFKA-8485) Kafka connect worker does not respond when kafka broker goes down with data streaming in progress

[ https://issues.apache.org/jira/browse/KAFKA-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858367#comment-16858367 ] kaushik srinivas commented on KAFKA-8485: - I have a query in this scenario, KafkaBasedLog.java

[jira] [Commented] (KAFKA-8485) Kafka connect worker does not respond when kafka broker goes down with data streaming in progress

[ https://issues.apache.org/jira/browse/KAFKA-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858366#comment-16858366 ] kaushik srinivas commented on KAFKA-8485: - Hi [~kkonstantine] I see weird behavior across

[jira] [Commented] (KAFKA-8501) Remove key and value from exception message

[ https://issues.apache.org/jira/browse/KAFKA-8501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858362#comment-16858362 ] Carlos Manuel Duclos Vergara commented on KAFKA-8501: - Hi, I'd like to work on this

[jira] [Assigned] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-8461: Assignee: Manikumar > Flakey test >

[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16858346#comment-16858346 ] ASF GitHub Bot commented on KAFKA-8461: --- omkreddy commented on pull request #6887: KAFKA-8461: Wait

[jira] [Resolved] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

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

[jira] [Created] (KAFKA-8503) AdminClient should ignore retries config if a custom timeout is provided

Jason Gustafson created KAFKA-8503: -- Summary: AdminClient should ignore retries config if a custom timeout is provided Key: KAFKA-8503 URL: https://issues.apache.org/jira/browse/KAFKA-8503 Project:

[jira] [Created] (KAFKA-8502) Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions

Boyang Chen created KAFKA-8502: -- Summary: Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions Key: KAFKA-8502 URL: https://issues.apache.org/jira/browse/KAFKA-8502 Project:

[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

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