[jira] [Updated] (KAFKA-8864) Kafka Producer deadlocked on flush call

2019-09-03 Thread Shaan Appel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaan Appel updated KAFKA-8864: --- Description: Some times the {{producer.flush}} call will be blocked by some lock. This may have

[jira] [Created] (KAFKA-8864) Kafka Producer deadlocked on flush call

2019-09-03 Thread Shaan Appel (Jira)
Shaan Appel created KAFKA-8864: -- Summary: Kafka Producer deadlocked on flush call Key: KAFKA-8864 URL: https://issues.apache.org/jira/browse/KAFKA-8864 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8846) Unexpected results joining a KStream to a KTable after repartitioning

2019-09-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921757#comment-16921757 ] Matthias J. Sax commented on KAFKA-8846: `TopologyTestDriver` executes topologies slightly

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

2019-09-03 Thread Vikas Singh (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh updated KAFKA-8813: --- Description: In Partition.createLog we do: {code:java} val props = stateStore.fetchTopicConfig() val

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

2019-09-03 Thread Vikas Singh (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh updated KAFKA-8813: --- Description: In Partition.createLog we do: {code:java} val props = stateStore.fetchTopicConfig() val

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

2019-09-03 Thread Vikas Singh (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh updated KAFKA-8813: --- Description: In Partition.createLog we do: {code:java} val props = stateStore.fetchTopicConfig() val

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

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921726#comment-16921726 ] ASF GitHub Bot commented on KAFKA-8853: --- scott-hendricks commented on pull request #7289:

[jira] [Commented] (KAFKA-8676) Avoid Stopping Unnecessary Connectors and Tasks

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921714#comment-16921714 ] ASF GitHub Bot commented on KAFKA-8676: --- rhauch commented on pull request #7287: MINOR: Add unit

[jira] [Commented] (KAFKA-8676) Avoid Stopping Unnecessary Connectors and Tasks

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921713#comment-16921713 ] ASF GitHub Bot commented on KAFKA-8676: --- rhauch commented on pull request #7097: KAFKA-8676: Avoid

[jira] [Commented] (KAFKA-7931) Java Client: if all ephemeral brokers fail, client can never reconnect to brokers

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921709#comment-16921709 ] ASF GitHub Bot commented on KAFKA-7931: --- aravindvs commented on pull request #7288: KAFKA-7931 :

[jira] [Commented] (KAFKA-8676) Avoid Stopping Unnecessary Connectors and Tasks

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921651#comment-16921651 ] ASF GitHub Bot commented on KAFKA-8676: --- kkonstantine commented on pull request #7287: MINOR: Add

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

2019-09-03 Thread alex gabriel (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921598#comment-16921598 ] alex gabriel commented on KAFKA-3539: - [~tu...@avast.com] [~stevenz3wu] I think that you can avoid

[jira] [Commented] (KAFKA-8820) Use Admin API of Replica Reassignment in CLI tools

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921513#comment-16921513 ] ASF GitHub Bot commented on KAFKA-8820: --- steverod commented on pull request #7286: [KAFKA-8820]

[jira] [Commented] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921510#comment-16921510 ] Albert Lozano commented on KAFKA-8863: -- I am already working on this issue:

[jira] [Commented] (KAFKA-8558) KIP-479 - Add Materialized Overload to KStream#Join

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921506#comment-16921506 ] ASF GitHub Bot commented on KAFKA-8558: --- bbejeck commented on pull request #7285: KAFKA-8558: Add

[jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Albert Lozano updated KAFKA-8863: - Description:

[jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Albert Lozano updated KAFKA-8863: - Description:

[jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Albert Lozano updated KAFKA-8863: - Description:

[jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Albert Lozano updated KAFKA-8863: - Description:

[jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Albert Lozano updated KAFKA-8863: - Description:

[jira] [Updated] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Albert Lozano updated KAFKA-8863: - Description:

[jira] [Created] (KAFKA-8863) Add InsertHeader and DropHeaders connect transforms KIP-145

2019-09-03 Thread Albert Lozano (Jira)
Albert Lozano created KAFKA-8863: Summary: Add InsertHeader and DropHeaders connect transforms KIP-145 Key: KAFKA-8863 URL: https://issues.apache.org/jira/browse/KAFKA-8863 Project: Kafka

[jira] [Updated] (KAFKA-8862) Misleading exception message for non-existant partition

2019-09-03 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley updated KAFKA-8862: --- Flags: Patch Labels: patch-available (was: ) > Misleading exception message for non-existant

[jira] [Commented] (KAFKA-8862) Misleading exception message for non-existant partition

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921407#comment-16921407 ] ASF GitHub Bot commented on KAFKA-8862: --- tombentley commented on pull request #7283: KAFKA-8862:

[jira] [Created] (KAFKA-8862) Misleading exception message for non-existant partition

2019-09-03 Thread Tom Bentley (Jira)
Tom Bentley created KAFKA-8862: -- Summary: Misleading exception message for non-existant partition Key: KAFKA-8862 URL: https://issues.apache.org/jira/browse/KAFKA-8862 Project: Kafka Issue

[jira] [Commented] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

2019-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921324#comment-16921324 ] ASF GitHub Bot commented on KAFKA-8861: --- chia7712 commented on pull request #7281: KAFKA-8861 Fix

[jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

2019-09-03 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-8861: -- Component/s: unit tests > Fix flaky >

[jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

2019-09-03 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-8861: -- Description: This is similar to KAFKA-8011 and KAFKA-8026. The error stack is shown below.

[jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

2019-09-03 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-8861: -- Labels: flaky-test (was: ) > Fix flaky >

[jira] [Updated] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

2019-09-03 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-8861: -- Component/s: streams > Fix flaky >

[jira] [Created] (KAFKA-8861) Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic

2019-09-03 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-8861: - Summary: Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic Key: KAFKA-8861 URL: https://issues.apache.org/jira/browse/KAFKA-8861

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

2019-09-03 Thread Patrik Kleindl (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921289#comment-16921289 ] Patrik Kleindl commented on KAFKA-5998: --- Timeline for 2.4 is here 

[jira] [Updated] (KAFKA-8858) Kafka Streams - Failed to Rebalance Error and stream consumer stuck for some reason

2019-09-03 Thread Ante B. (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ante B. updated KAFKA-8858: --- Environment: Apache Kafka 2.1.1 (was: Apache Kakfa 2.1.1) > Kafka Streams - Failed to Rebalance Error and

[jira] [Updated] (KAFKA-8611) Add KStream#repartition operation

2019-09-03 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: - Fix Version/s: 2.4.0 > Add KStream#repartition operation >

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

2019-09-03 Thread Harsh Singh (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921204#comment-16921204 ] Harsh Singh commented on KAFKA-5998: Hi, appreciate if timeline for releasing the fixed version for