[jira] [Commented] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection

2017-07-26 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101249#comment-16101249 ] huxihx commented on KAFKA-5641: --- [~ijuma] "The broker only processes one request at a time,

[jira] [Updated] (KAFKA-5501) introduce async ZookeeperClient

2017-07-26 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5501: Summary: introduce async ZookeeperClient (was: use async zookeeper apis everywhere) > introduce as

[jira] [Created] (KAFKA-5642) use async ZookeeperClient everywhere

2017-07-26 Thread Onur Karaman (JIRA)
Onur Karaman created KAFKA-5642: --- Summary: use async ZookeeperClient everywhere Key: KAFKA-5642 URL: https://issues.apache.org/jira/browse/KAFKA-5642 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-5501) introduce async ZookeeperClient

2017-07-26 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5501: Description: Synchronous zookeeper apis means that we wait an entire round trip before doing the nex

[jira] [Resolved] (KAFKA-5501) introduce async ZookeeperClient

2017-07-26 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman resolved KAFKA-5501. - Resolution: Fixed > introduce async ZookeeperClient > --- > >

[jira] [Commented] (KAFKA-5501) introduce async ZookeeperClient

2017-07-26 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101268#comment-16101268 ] Onur Karaman commented on KAFKA-5501: - [~ijuma] I went ahead and reworded this ticket

[jira] [Commented] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101273#comment-16101273 ] Ismael Juma commented on KAFKA-5641: My comment was about the broker. And yes, the bro

[jira] [Comment Edited] (KAFKA-5641) Metadata request should always be allowed to send no regardless of value for max.in.flight.requests.per.connection

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101273#comment-16101273 ] Ismael Juma edited comment on KAFKA-5641 at 7/26/17 7:27 AM: -

[jira] [Commented] (KAFKA-5562) Do streams state directory cleanup on a single thread

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101401#comment-16101401 ] ASF GitHub Bot commented on KAFKA-5562: --- Github user asfgit closed the pull request

[jira] [Created] (KAFKA-5643) Using _DUCKTAPE_OPTIONS has no effect on executing tests

2017-07-26 Thread Paolo Patierno (JIRA)
Paolo Patierno created KAFKA-5643: - Summary: Using _DUCKTAPE_OPTIONS has no effect on executing tests Key: KAFKA-5643 URL: https://issues.apache.org/jira/browse/KAFKA-5643 Project: Kafka Issu

[jira] [Commented] (KAFKA-5643) Using _DUCKTAPE_OPTIONS has no effect on executing tests

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101465#comment-16101465 ] ASF GitHub Bot commented on KAFKA-5643: --- GitHub user ppatierno opened a pull request

[jira] [Created] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime

2017-07-26 Thread Manikumar (JIRA)
Manikumar created KAFKA-5644: Summary: Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime Key: KAFKA-5644 URL: https://issues.apache.org/jira/browse/KAFKA-5644 Project: K

[jira] [Commented] (KAFKA-5592) Connection with plain client to SSL-secured broker causes OOM

2017-07-26 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101565#comment-16101565 ] Marcin Łuczyński commented on KAFKA-5592: - It's very likely. > Connection with pl

[jira] [Commented] (KAFKA-5386) [Kafka Streams] - custom name for state-store change-log topic

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101652#comment-16101652 ] Matthias J. Sax commented on KAFKA-5386: Understood. Technically, it would be poss

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101659#comment-16101659 ] Matthias J. Sax commented on KAFKA-4327: It's Streams tool, so it belongs to packa

[jira] [Resolved] (KAFKA-3210) Using asynchronous calls through the raw ZK API in ZkUtils

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3210. Resolution: Won't Fix We are following a slightly different approach, see KAFKA-5501. > Using async

[jira] [Resolved] (KAFKA-5328) consider switching json parser from scala to jackson

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5328. Resolution: Duplicate Duplicate of KAFKA-1595. > consider switching json parser from scala to jacks

[jira] [Updated] (KAFKA-5642) Use async ZookeeperClient in Controller

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5642: --- Summary: Use async ZookeeperClient in Controller (was: use async ZookeeperClient everywhere) > Use a

[jira] [Created] (KAFKA-5645) Use async ZookeeperClient in SimpleAclAuthorizer

2017-07-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-5645: -- Summary: Use async ZookeeperClient in SimpleAclAuthorizer Key: KAFKA-5645 URL: https://issues.apache.org/jira/browse/KAFKA-5645 Project: Kafka Issue Type: Sub-ta

[jira] [Created] (KAFKA-5646) Use async ZookeeperClient for Config and ISR management

2017-07-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-5646: -- Summary: Use async ZookeeperClient for Config and ISR management Key: KAFKA-5646 URL: https://issues.apache.org/jira/browse/KAFKA-5646 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5647) Use async ZookeeperClient for Admin operations

2017-07-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-5647: -- Summary: Use async ZookeeperClient for Admin operations Key: KAFKA-5647 URL: https://issues.apache.org/jira/browse/KAFKA-5647 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-5642) Use async ZookeeperClient in Controller

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101713#comment-16101713 ] Ismael Juma commented on KAFKA-5642: [~onurkaraman], I took a stab at splitting this J

[jira] [Commented] (KAFKA-3038) Speeding up partition reassignment after broker failure

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101716#comment-16101716 ] ASF GitHub Bot commented on KAFKA-3038: --- Github user resetius closed the pull reques

[jira] [Commented] (KAFKA-1595) Remove deprecated and slower scala JSON parser

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101715#comment-16101715 ] ASF GitHub Bot commented on KAFKA-1595: --- Github user resetius closed the pull reques

[jira] [Created] (KAFKA-5648) make Merger extend Aggregator

2017-07-26 Thread Clemens Valiente (JIRA)
Clemens Valiente created KAFKA-5648: --- Summary: make Merger extend Aggregator Key: KAFKA-5648 URL: https://issues.apache.org/jira/browse/KAFKA-5648 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-5649) Producer is being closed generating ssl exception

2017-07-26 Thread Pablo Panero (JIRA)
Pablo Panero created KAFKA-5649: --- Summary: Producer is being closed generating ssl exception Key: KAFKA-5649 URL: https://issues.apache.org/jira/browse/KAFKA-5649 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)

2017-07-26 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5650: - Summary: Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182) Key: KAFKA-5650 URL: https://issues.apache.org/jira/browse/KAFKA-5650 Proje

[jira] [Updated] (KAFKA-5649) Producer is being closed generating ssl exception

2017-07-26 Thread Pablo Panero (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Panero updated KAFKA-5649: Description: On a streaming job using built-in kafka source and sink (over SSL), with I am getting

[jira] [Created] (KAFKA-5651) KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines

2017-07-26 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5651: - Summary: KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines Key: KAFKA-5651 URL: https://issues.apache.org/jira/browse/KAFKA-5651 Project:

[jira] [Updated] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)

2017-07-26 Thread Damian Guy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5650: -- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5651 > Provide a simple way for custom storage en

[jira] [Created] (KAFKA-5652) Add new api methods to KStream

2017-07-26 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5652: - Summary: Add new api methods to KStream Key: KAFKA-5652 URL: https://issues.apache.org/jira/browse/KAFKA-5652 Project: Kafka Issue Type: Sub-task Repor

[jira] [Created] (KAFKA-5653) Add new API methods to KTable

2017-07-26 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5653: - Summary: Add new API methods to KTable Key: KAFKA-5653 URL: https://issues.apache.org/jira/browse/KAFKA-5653 Project: Kafka Issue Type: Sub-task Report

[jira] [Created] (KAFKA-5654) Add new API methods to KGroupedStream

2017-07-26 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5654: - Summary: Add new API methods to KGroupedStream Key: KAFKA-5654 URL: https://issues.apache.org/jira/browse/KAFKA-5654 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5655) Add new API methods to KGroupedTable

2017-07-26 Thread Damian Guy (JIRA)
Damian Guy created KAFKA-5655: - Summary: Add new API methods to KGroupedTable Key: KAFKA-5655 URL: https://issues.apache.org/jira/browse/KAFKA-5655 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5656) Support bulk attributes request on KafkaMbean where some attributes do not exist

2017-07-26 Thread Erik Kringen (JIRA)
Erik Kringen created KAFKA-5656: --- Summary: Support bulk attributes request on KafkaMbean where some attributes do not exist Key: KAFKA-5656 URL: https://issues.apache.org/jira/browse/KAFKA-5656 Project:

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-07-26 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101932#comment-16101932 ] Jiangjie Qin commented on KAFKA-5621: - [~ijuma] [~apurva] The expiration for messages

[jira] [Commented] (KAFKA-5656) Support bulk attributes request on KafkaMbean where some attributes do not exist

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101941#comment-16101941 ] ASF GitHub Bot commented on KAFKA-5656: --- GitHub user ErikKringen opened a pull reque

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101966#comment-16101966 ] Ewen Cheslack-Postava commented on KAFKA-4327: -- [~mjsax] We'd have to decide

[jira] [Commented] (KAFKA-5341) Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101975#comment-16101975 ] ASF GitHub Bot commented on KAFKA-5341: --- GitHub user lindong28 opened a pull request

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-07-26 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102096#comment-16102096 ] Apurva Mehta commented on KAFKA-5621: - > The expiration for messages in the accumulato

[jira] [Commented] (KAFKA-5648) make Merger extend Aggregator

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102119#comment-16102119 ] Matthias J. Sax commented on KAFKA-5648: Your observation is correct, that {{Merge

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102134#comment-16102134 ] Matthias J. Sax commented on KAFKA-4327: It is definitely part of public API, and

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102147#comment-16102147 ] Ismael Juma commented on KAFKA-4327: We discussed this at the time and we documented t

[jira] [Created] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

2017-07-26 Thread Randall Hauch (JIRA)
Randall Hauch created KAFKA-5657: Summary: Connect REST API should include the connector type when describing a connector Key: KAFKA-5657 URL: https://issues.apache.org/jira/browse/KAFKA-5657 Project:

[jira] [Updated] (KAFKA-4279) REST endpoint to list converter plugins

2017-07-26 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-4279: - Labels: needs-kip newbie (was: ) > REST endpoint to list converter plugins >

[jira] [Updated] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

2017-07-26 Thread Randall Hauch (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5657: - Description: Kafka Connect's REST API's {{connectors/}} and {{connectors/\{name\}}} endpoints sho

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-07-26 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102176#comment-16102176 ] Jiangjie Qin commented on KAFKA-5621: - [~apurva] Yes, I agree that expiry ms is a new

[jira] [Commented] (KAFKA-5505) Connect: Do not restart connector and existing tasks on task-set change

2017-07-26 Thread Per Steffensen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102200#comment-16102200 ] Per Steffensen commented on KAFKA-5505: --- bq. There's been some discussion about more

[jira] [Created] (KAFKA-5658) adminclient will stop working after some amount of time

2017-07-26 Thread dan norwood (JIRA)
dan norwood created KAFKA-5658: -- Summary: adminclient will stop working after some amount of time Key: KAFKA-5658 URL: https://issues.apache.org/jira/browse/KAFKA-5658 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5658) adminclient will stop working after some amount of time

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5658: --- Labels: reliability (was: ) > adminclient will stop working after some amount of time > -

[jira] [Updated] (KAFKA-5658) adminclient will stop working after some amount of time

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5658: --- Priority: Critical (was: Major) > adminclient will stop working after some amount of time > -

[jira] [Updated] (KAFKA-5658) adminclient will stop working after some amount of time

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5658: --- Fix Version/s: 0.11.0.1 > adminclient will stop working after some amount of time > --

[jira] [Assigned] (KAFKA-5658) adminclient will stop working after some amount of time

2017-07-26 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5658: -- Assignee: Colin P. McCabe > adminclient will stop working after some amount of time > -

[jira] [Updated] (KAFKA-5658) Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions

2017-07-26 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5658: --- Summary: Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailabl

[jira] [Updated] (KAFKA-5658) Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions

2017-07-26 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-5658: --- Description: The AdminClient does not properly clear calls from the callsInFlight structure.

[jira] [Commented] (KAFKA-5658) Fix AdminClient request timeout handling bug resulting in continual BrokerNotAvailableExceptions

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102290#comment-16102290 ] ASF GitHub Bot commented on KAFKA-5658: --- GitHub user cmccabe opened a pull request:

[jira] [Created] (KAFKA-5659) AdminClient#describeConfigs makes an extra empty request when only broker info is requested

2017-07-26 Thread Colin P. McCabe (JIRA)
Colin P. McCabe created KAFKA-5659: -- Summary: AdminClient#describeConfigs makes an extra empty request when only broker info is requested Key: KAFKA-5659 URL: https://issues.apache.org/jira/browse/KAFKA-5659

[jira] [Commented] (KAFKA-5659) AdminClient#describeConfigs makes an extra empty request when only broker info is requested

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102309#comment-16102309 ] ASF GitHub Bot commented on KAFKA-5659: --- GitHub user cmccabe opened a pull request:

[jira] [Created] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

2017-07-26 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-5660: -- Summary: Don't throw TopologyBuilderException during runtime Key: KAFKA-5660 URL: https://issues.apache.org/jira/browse/KAFKA-5660 Project: Kafka Issue T

[jira] [Commented] (KAFKA-5621) The producer should retry expired batches when retries are enabled

2017-07-26 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102313#comment-16102313 ] Apurva Mehta commented on KAFKA-5621: - I think the core dichotomy is that we have mirr

[jira] [Created] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance

2017-07-26 Thread Apurva Mehta (JIRA)
Apurva Mehta created KAFKA-5661: --- Summary: Develop and understanding of how to tune transactions for optimal performance Key: KAFKA-5661 URL: https://issues.apache.org/jira/browse/KAFKA-5661 Project: Ka

[jira] [Updated] (KAFKA-5662) We should be able to specify min.insync.replicas for the __consumer_offsets topic

2017-07-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5662: --- Labels: needs-kip (was: ) > We should be able to specify min.insync.replicas for the __consum

[jira] [Created] (KAFKA-5662) We should be able to specify min.insync.replicas for the __consumer_offsets topic

2017-07-26 Thread Apurva Mehta (JIRA)
Apurva Mehta created KAFKA-5662: --- Summary: We should be able to specify min.insync.replicas for the __consumer_offsets topic Key: KAFKA-5662 URL: https://issues.apache.org/jira/browse/KAFKA-5662 Project

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102357#comment-16102357 ] Matthias J. Sax commented on KAFKA-4327: Thanks [~ijuma]! This clarifies it. > Mo

[jira] [Created] (KAFKA-5663) LogDirFailureTest system test fails

2017-07-26 Thread Apurva Mehta (JIRA)
Apurva Mehta created KAFKA-5663: --- Summary: LogDirFailureTest system test fails Key: KAFKA-5663 URL: https://issues.apache.org/jira/browse/KAFKA-5663 Project: Kafka Issue Type: Bug R

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-07-26 Thread Apurva Mehta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102370#comment-16102370 ] Apurva Mehta commented on KAFKA-5663: - [~lindong] I assigned this to you since you add

[jira] [Commented] (KAFKA-4327) Move Reset Tool from core to streams

2017-07-26 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102394#comment-16102394 ] Guozhang Wang commented on KAFKA-4327: -- +1 to what [~ijuma] said. > Move Reset Tool

[jira] [Created] (KAFKA-5664) Disable auto offset commit in ConsoleConsumer if no group is provided

2017-07-26 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-5664: -- Summary: Disable auto offset commit in ConsoleConsumer if no group is provided Key: KAFKA-5664 URL: https://issues.apache.org/jira/browse/KAFKA-5664 Project: Kafk

[jira] [Commented] (KAFKA-5663) LogDirFailureTest system test fails

2017-07-26 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102403#comment-16102403 ] Dong Lin commented on KAFKA-5663: - Thanks [~apurva]. I will look into this. > LogDirFailu

[jira] [Assigned] (KAFKA-5664) Disable auto offset commit in ConsoleConsumer if no group is provided

2017-07-26 Thread Vahid Hashemian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5664: -- Assignee: Vahid Hashemian > Disable auto offset commit in ConsoleConsumer if no group i

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

2017-07-26 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102622#comment-16102622 ] huxihx commented on KAFKA-5007: --- [~joseph.alias...@gmail.com] what's the status for this jir

[jira] [Created] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread

2017-07-26 Thread huxihx (JIRA)
huxihx created KAFKA-5665: - Summary: Incorrect interruption invoking method used for Heartbeat thread Key: KAFKA-5665 URL: https://issues.apache.org/jira/browse/KAFKA-5665 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-5665) Incorrect interruption invoking method used for Heartbeat thread

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102661#comment-16102661 ] ASF GitHub Bot commented on KAFKA-5665: --- GitHub user huxihx opened a pull request:

[jira] [Updated] (KAFKA-5341) Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics

2017-07-26 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5341: - Fix Version/s: 1.0.0 > Add UnderMinIsrPartitionCount and per-partition UnderMinIsr

[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2017-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102758#comment-16102758 ] ASF GitHub Bot commented on KAFKA-5611: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5611) One or more consumers in a consumer-group stop consuming after rebalancing

2017-07-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16102759#comment-16102759 ] Jason Gustafson commented on KAFKA-5611: [~pskianis] We have merged the patch abov