[jira] [Created] (KAFKA-5871) bound the throttle time in byte rate quota

Jun Rao created KAFKA-5871: -- Summary: bound the throttle time in byte rate quota Key: KAFKA-5871 URL: https://issues.apache.org/jira/browse/KAFKA-5871 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5854) Handle SASL authentication failures as non-retriable exceptions in clients

[ https://issues.apache.org/jira/browse/KAFKA-5854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162263#comment-16162263 ] ASF GitHub Bot commented on KAFKA-5854: --- GitHub user vahidhashemian opened a pull request:

[jira] [Commented] (KAFKA-5520) Extend Consumer Group Reset Offset tool for Stream Applications

[ https://issues.apache.org/jira/browse/KAFKA-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162212#comment-16162212 ] ASF GitHub Bot commented on KAFKA-5520: --- GitHub user jeqo opened a pull request:

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

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162199#comment-16162199 ] Ismael Juma commented on KAFKA-5621: [~sutambe], since KIP-91 has enough votes, we should probably

[jira] [Updated] (KAFKA-5797) StoreChangelogReader should be resilient to broker-side metadata not available

[ https://issues.apache.org/jira/browse/KAFKA-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5797: - Fix Version/s: 0.11.0.1 > StoreChangelogReader should be resilient to broker-side metadata not

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

[ https://issues.apache.org/jira/browse/KAFKA-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5621: -- Assignee: Sumant Tambe (was: Apurva Mehta) > The producer should retry expired batches when

[jira] [Updated] (KAFKA-5869) SMT to select Kafka topic based on field in message key or value

[ https://issues.apache.org/jira/browse/KAFKA-5869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5869: - Labels: needs-kip (was: ) > SMT to select Kafka topic based on field in message key or value >

[jira] [Commented] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161995#comment-16161995 ] Apurva Mehta commented on KAFKA-5870: - One option to solve this is to delay the reset until all in

[jira] [Created] (KAFKA-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

Apurva Mehta created KAFKA-5870: --- Summary: Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions Key: KAFKA-5870 URL:

[jira] [Created] (KAFKA-5869) SMT to select Kafka topic based on field in message key or value

Yeva Byzek created KAFKA-5869: - Summary: SMT to select Kafka topic based on field in message key or value Key: KAFKA-5869 URL: https://issues.apache.org/jira/browse/KAFKA-5869 Project: Kafka

[jira] [Commented] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

[ https://issues.apache.org/jira/browse/KAFKA-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161895#comment-16161895 ] ASF GitHub Bot commented on KAFKA-5817: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-4747) add metrics for KafkaConsumer.poll

[ https://issues.apache.org/jira/browse/KAFKA-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman resolved KAFKA-4747. - Resolution: Won't Fix [~junrao] pointed out that the distinction between tim-in-poll and

[jira] [Comment Edited] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161757#comment-16161757 ] Raoufeh Hashemian edited comment on KAFKA-5857 at 9/11/17 6:41 PM: --- We

[jira] [Commented] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161757#comment-16161757 ] Raoufeh Hashemian commented on KAFKA-5857: -- We have 960 partition for this topic, I wonder what

[jira] [Commented] (KAFKA-4747) add metrics for KafkaConsumer.poll

[ https://issues.apache.org/jira/browse/KAFKA-4747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161708#comment-16161708 ] ASF GitHub Bot commented on KAFKA-4747: --- Github user onurkaraman closed the pull request at:

[jira] [Commented] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161690#comment-16161690 ] Matthias J. Sax commented on KAFKA-5861: Thanks for reporting this. What do you exactly mean by

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

[ https://issues.apache.org/jira/browse/KAFKA-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161534#comment-16161534 ] ASF GitHub Bot commented on KAFKA-5655: --- GitHub user dguy opened a pull request:

[jira] [Assigned] (KAFKA-5384) KIP-162: Enable topic deletion by default

[ https://issues.apache.org/jira/browse/KAFKA-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5384: -- Assignee: Gwen Shapira > KIP-162: Enable topic deletion by default >

[jira] [Comment Edited] (KAFKA-4392) Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-4392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161405#comment-16161405 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-4392 at 9/11/17 3:01 PM:

[jira] [Resolved] (KAFKA-5763) Refactor NetworkClient to use LogContext

[ https://issues.apache.org/jira/browse/KAFKA-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5763. Resolution: Fixed > Refactor NetworkClient to use LogContext >

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

[ https://issues.apache.org/jira/browse/KAFKA-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161342#comment-16161342 ] ASF GitHub Bot commented on KAFKA-5654: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-4741) Memory leak in RecordAccumulator.append

[ https://issues.apache.org/jira/browse/KAFKA-4741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161251#comment-16161251 ] Scott Pettyjohn commented on KAFKA-4741: I recently ran into this issue. I am using kafka-clients

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161144#comment-16161144 ] pranay kumar commented on KAFKA-1614: - Thanks [~sergey.vergun] for reply. When I am trying to install

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161127#comment-16161127 ] Sergey Vergun commented on KAFKA-1614: -- [~krpranay] You need to download the source code for the

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161077#comment-16161077 ] pranay kumar commented on KAFKA-1614: - Hi, I have kafka version 0.8.2.1.0. And kafka manager working

[jira] [Commented] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

[ https://issues.apache.org/jira/browse/KAFKA-5816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161069#comment-16161069 ] ASF GitHub Bot commented on KAFKA-5816: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohsen Zainalpour resolved KAFKA-5855. -- Resolution: Invalid > records-lag is always zero > -- > >

[jira] [Commented] (KAFKA-5855) records-lag is always zero

[ https://issues.apache.org/jira/browse/KAFKA-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160964#comment-16160964 ] Mohsen Zainalpour commented on KAFKA-5855: -- Thanks. Actually It was my misunderstanding. Consumer

[jira] [Commented] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

[ https://issues.apache.org/jira/browse/KAFKA-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160962#comment-16160962 ] ASF GitHub Bot commented on KAFKA-5817: --- GitHub user dguy opened a pull request:

[jira] [Commented] (KAFKA-5531) Check exception handling in all streams tests

[ https://issues.apache.org/jira/browse/KAFKA-5531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160931#comment-16160931 ] ASF GitHub Bot commented on KAFKA-5531: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-5600) Group loading regression causing stale metadata/offsets cache

[ https://issues.apache.org/jira/browse/KAFKA-5600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160875#comment-16160875 ] Ismael Juma commented on KAFKA-5600: The voting process for 0.11.0.1 is in progress. It will be

[jira] [Issue Comment Deleted] (KAFKA-5060) Offset not found while broker is rebuilding its index after an index corruption

[ https://issues.apache.org/jira/browse/KAFKA-5060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Romaric Parmentier updated KAFKA-5060: -- Comment: was deleted (was: Thank you for your email. I’m out of the office and will be

[jira] [Commented] (KAFKA-5600) Group loading regression causing stale metadata/offsets cache

[ https://issues.apache.org/jira/browse/KAFKA-5600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160858#comment-16160858 ] Jan Burkhardt commented on KAFKA-5600: -- we have build a patched 0.11.0 version

[jira] [Commented] (KAFKA-5860) Prevent non-consecutive partition ids

[ https://issues.apache.org/jira/browse/KAFKA-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160852#comment-16160852 ] huxihx commented on KAFKA-5860: --- Seems it's related to

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

[ https://issues.apache.org/jira/browse/KAFKA-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16160845#comment-16160845 ] Per Steffensen commented on KAFKA-5505: --- Just realized that SourceConnector has a initialize method

[jira] [Updated] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nandish Kotadia updated KAFKA-5868: --- Description: up vote 0 down vote favorite 1 I have a Kafka Streams Application which takes

[jira] [Updated] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nandish Kotadia updated KAFKA-5868: --- Description: up vote 0 down vote favorite 1 I have a Kafka Streams Application which takes

[jira] [Created] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

Nandish Kotadia created KAFKA-5868: -- Summary: Kafka Consumer Rebalancing takes too long Key: KAFKA-5868 URL: https://issues.apache.org/jira/browse/KAFKA-5868 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5861) KStream close( withTimeout ) - does not work under load conditions in the multi-threaded KStream application

[ https://issues.apache.org/jira/browse/KAFKA-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki updated KAFKA-5861: -- Summary: KStream close( withTimeout ) - does not work under load