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

2019-06-28 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8609: --- Description: We would like to track some additional metrics on the consumer side

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

2019-06-28 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8609: --- Description: We would like to track some additional metrics on the consumer side

[jira] [Commented] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

2019-06-28 Thread TEJAL ADSUL (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875330#comment-16875330 ] TEJAL ADSUL commented on KAFKA-8592: On further debugging the issue, the auto resolution is actually

[jira] [Updated] (KAFKA-8592) Broker Dynamic Configuration fails to resolve variables as per KIP-421

2019-06-28 Thread TEJAL ADSUL (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TEJAL ADSUL updated KAFKA-8592: --- Summary: Broker Dynamic Configuration fails to resolve variables as per KIP-421 (was: Broker

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

2019-06-28 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875325#comment-16875325 ] Boyang Chen commented on KAFKA-8391: Failed again: 

[jira] [Commented] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

2019-06-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875310#comment-16875310 ] ASF GitHub Bot commented on KAFKA-8616: --- abbccdda commented on pull request #7015: KAFKA-8616: use

[jira] [Updated] (KAFKA-8615) Change to track partition time breaks TimestampExtractor

2019-06-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8615: --- Component/s: streams > Change to track partition time breaks TimestampExtractor >

[jira] [Assigned] (KAFKA-8614) Rename the `responses` field of IncrementalAlterConfigsResponse to match AlterConfigs

2019-06-28 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett reassigned KAFKA-8614: -- Assignee: Bob Barrett > Rename the `responses` field of IncrementalAlterConfigsResponse to

[jira] [Created] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

2019-06-28 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8616: -- Summary: Replace ApiVersionsRequest request/response with automated protocol Key: KAFKA-8616 URL: https://issues.apache.org/jira/browse/KAFKA-8616 Project: Kafka

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

2019-06-28 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8492. Resolution: Fixed Fix Version/s: 2.4.0 > Modify ConsumerCoordinator Algorithm with

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

2019-06-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875204#comment-16875204 ] ASF GitHub Bot commented on KAFKA-8355: --- abbccdda commented on pull request #7014: KAFKA-8355: add

[jira] [Created] (KAFKA-8615) Change to track partition time breaks TimestampExtractor

2019-06-28 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8615: -- Summary: Change to track partition time breaks TimestampExtractor Key: KAFKA-8615 URL: https://issues.apache.org/jira/browse/KAFKA-8615 Project: Kafka Issue

[jira] [Updated] (KAFKA-8614) Rename the `responses` field of IncrementalAlterConfigsResponse to match AlterConfigs

2019-06-28 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-8614: --- Description: IncrementalAlterConfigsResponse and AlterConfigsResponse have an identical structure

[jira] [Updated] (KAFKA-8614) Rename the `responses` field of IncrementalAlterConfigsResponse to match AlterConfigs

2019-06-28 Thread Bob Barrett (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-8614: --- Description: IncrementalAlterConfigsResponse and AlterConfigsResponse have an identical structure

[jira] [Created] (KAFKA-8614) Rename the `responses` field of IncrementalAlterConfigsResponse to match AlterConfigs

2019-06-28 Thread Bob Barrett (JIRA)
Bob Barrett created KAFKA-8614: -- Summary: Rename the `responses` field of IncrementalAlterConfigsResponse to match AlterConfigs Key: KAFKA-8614 URL: https://issues.apache.org/jira/browse/KAFKA-8614

[jira] [Assigned] (KAFKA-6037) Make Sub-topology Parallelism Tunable

2019-06-28 Thread Levani Kokhreidze (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze reassigned KAFKA-6037: Assignee: Levani Kokhreidze (was: Boyang Chen) > Make Sub-topology Parallelism

[jira] [Assigned] (KAFKA-4835) Allow users control over repartitioning

2019-06-28 Thread Levani Kokhreidze (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze reassigned KAFKA-4835: Assignee: Levani Kokhreidze > Allow users control over repartitioning >

[jira] [Commented] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Levani Kokhreidze (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875091#comment-16875091 ] Levani Kokhreidze commented on KAFKA-8611: -- Great! Thank you, will do, > Make topic optional

[jira] [Commented] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875087#comment-16875087 ] Matthias J. Sax commented on KAFKA-8611: [~lkokhreidze], I added you to the list of contributors

[jira] [Assigned] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8611: -- Assignee: Levani Kokhreidze > Make topic optional when using through() operations in

[jira] [Commented] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875085#comment-16875085 ] Matthias J. Sax commented on KAFKA-8611: Might be easiest to do all at once with one umbrella

[jira] [Commented] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Levani Kokhreidze (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875078#comment-16875078 ] Levani Kokhreidze commented on KAFKA-8611: -- Happy to work on that as well, can be really useful

[jira] [Commented] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875060#comment-16875060 ] Matthias J. Sax commented on KAFKA-8611: Thanks the ticket. Seems to overlap with 

[jira] [Commented] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

2019-06-28 Thread Ryanne Dolan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16875021#comment-16875021 ] Ryanne Dolan commented on KAFKA-7077: - [~vpernin] yes, this is a frequent ask for MM2. Would love to

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Updated] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8612: Description: Cluster of 5 brokers, `Kafka 2.1.1`. m5.large (2 CPU, 8GB RAM) instances. Kafka Streams

[jira] [Commented] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

2019-06-28 Thread Vladislav Pernin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16874952#comment-16874952 ] Vladislav Pernin commented on KAFKA-7077: - I'm wondering if this is not becoming especially

[jira] [Assigned] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

2019-06-28 Thread Vladislav Pernin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Pernin reassigned KAFKA-7077: --- Assignee: Vladislav Pernin (was: Stephane Maarek) > KIP-318: Make Kafka Connect

[jira] [Assigned] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

2019-06-28 Thread Vladislav Pernin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vladislav Pernin reassigned KAFKA-7077: --- Assignee: Stephane Maarek (was: Vladislav Pernin) > KIP-318: Make Kafka Connect

[jira] [Created] (KAFKA-8613) Set default grace period to 0

2019-06-28 Thread Bruno Cadonna (JIRA)
Bruno Cadonna created KAFKA-8613: Summary: Set default grace period to 0 Key: KAFKA-8613 URL: https://issues.apache.org/jira/browse/KAFKA-8613 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8612) Broker removes consumers from CG, Streams app gets stuck

2019-06-28 Thread Di Campo (JIRA)
Di Campo created KAFKA-8612: --- Summary: Broker removes consumers from CG, Streams app gets stuck Key: KAFKA-8612 URL: https://issues.apache.org/jira/browse/KAFKA-8612 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position & Cache truncation

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8608: Description: I added two brokers (brokerId 4,5) to a 3-node (brokerId 1,2,3) cluster where there were 32

[jira] [Updated] (KAFKA-8608) Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position & Cache truncation

2019-06-28 Thread Di Campo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Campo updated KAFKA-8608: Summary: Broker shows WARN on reassignment partitions on new brokers: Replica LEO, follower position &

[jira] [Updated] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin updated KAFKA-8611: --- Labels: needs-kip (was: ) > Make topic optional when using through() operations in DSL >

[jira] [Updated] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Levani Kokhreidze (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-8611: - Labels: (was: needs-kip) > Make topic optional when using through() operations in DSL

[jira] [Created] (KAFKA-8611) Make topic optional when using through() operations in DSL

2019-06-28 Thread Levani Kokhreidze (JIRA)
Levani Kokhreidze created KAFKA-8611: Summary: Make topic optional when using through() operations in DSL Key: KAFKA-8611 URL: https://issues.apache.org/jira/browse/KAFKA-8611 Project: Kafka

[jira] [Commented] (KAFKA-8546) Fix needed to avoid memory leak caused by JDK-6293787

2019-06-28 Thread Lee Dongjin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16874713#comment-16874713 ] Lee Dongjin commented on KAFKA-8546: [~badai] Absolutely. I agree with that approach. Right, the