[jira] [Assigned] (KAFKA-7204) MockConsumer poll clears all records in poll(), including records for subscriptions that are paused.

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7204: -- Assignee: Eduardo Pinto > MockConsumer poll clears all records in poll(), including

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971034#comment-16971034 ] Matthias J. Sax commented on KAFKA-9088: [~pierDipi] Added you to the list on contributors and

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971033#comment-16971033 ] Matthias J. Sax commented on KAFKA-9088: Sound like going with EasyMock is the better solution.

[jira] [Assigned] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9088: -- Assignee: Pierangelo Di Pilato > Consolidate InternalMockProcessorContext and

[jira] [Updated] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6718: --- Affects Version/s: (was: 1.1.0) > Rack Aware Stand-by Task Assignment for Kafka Streams

[jira] [Updated] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6718: --- Flags: (was: Patch,Important) > Rack Aware Stand-by Task Assignment for Kafka Streams >

[jira] [Assigned] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6718: -- Assignee: (was: Deepak Goyal) > Rack Aware Stand-by Task Assignment for Kafka

[jira] [Commented] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

2019-11-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971028#comment-16971028 ] ASF GitHub Bot commented on KAFKA-6718: --- mjsax commented on pull request #4785: KAFKA-6718: Rack

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971027#comment-16971027 ] Matthias J. Sax commented on KAFKA-9069:

[jira] [Updated] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2019-11-09 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9168: --- Component/s: streams > Integrate JNI direct buffer support to RocksDBStore >

[jira] [Created] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2019-11-09 Thread Sagar Rao (Jira)
Sagar Rao created KAFKA-9168: Summary: Integrate JNI direct buffer support to RocksDBStore Key: KAFKA-9168 URL: https://issues.apache.org/jira/browse/KAFKA-9168 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-8466) Remove 'jackson-module-scala' dependency (and replace it with some code)

2019-11-09 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970987#comment-16970987 ] Dejan Stojadinović commented on KAFKA-8466: --- [~ijuma] just to let you know: my priorities are

[jira] [Commented] (KAFKA-9106) metrics exposed via JMX shoud be configurable

2019-11-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970932#comment-16970932 ] ASF GitHub Bot commented on KAFKA-9106: --- xvrl commented on pull request #7674: KAFKA-9106 make

[jira] [Comment Edited] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

2019-11-09 Thread Peter Bukowinski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970917#comment-16970917 ] Peter Bukowinski edited comment on KAFKA-9044 at 11/9/19 7:11 PM: -- I had

[jira] [Commented] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

2019-11-09 Thread Peter Bukowinski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970917#comment-16970917 ] Peter Bukowinski commented on KAFKA-9044: - I had another broker dropout on one of my clusters.

[jira] [Commented] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

2019-11-09 Thread bibin sebastian (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970811#comment-16970811 ] bibin sebastian commented on KAFKA-8977: [~cadonna] ^^ > Remove MockStreamsMetrics Since it is

[jira] [Created] (KAFKA-9167) Implement a broker to controller request channel

2019-11-09 Thread Viktor Somogyi-Vass (Jira)
Viktor Somogyi-Vass created KAFKA-9167: -- Summary: Implement a broker to controller request channel Key: KAFKA-9167 URL: https://issues.apache.org/jira/browse/KAFKA-9167 Project: Kafka

[jira] [Created] (KAFKA-9166) Implement MetadataFetch API

2019-11-09 Thread Viktor Somogyi-Vass (Jira)
Viktor Somogyi-Vass created KAFKA-9166: -- Summary: Implement MetadataFetch API Key: KAFKA-9166 URL: https://issues.apache.org/jira/browse/KAFKA-9166 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

2019-11-09 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9022: - Fix Version/s: (was: 2.4.0) > Flaky Test KTableKTableForeignKeyJoinIntegrationTest. >

[jira] [Updated] (KAFKA-8948) Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple runs

2019-11-09 Thread Manikumar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8948: - Fix Version/s: (was: 2.4.0) > Flaky Test StreamsEosTest#test_rebalance_complex is broken for