[jira] [Issue Comment Deleted] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1716: Comment: was deleted (was: [~dchu] Do you mean that the fetchers have never been created? That

[jira] [Commented] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386022#comment-14386022 ] Jiangjie Qin commented on KAFKA-1716: - [~dchu] Do you mean that the fetchers

[jira] [Resolved] (KAFKA-1932) kafka topic (creation) templates

[ https://issues.apache.org/jira/browse/KAFKA-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-1932. - Resolution: Duplicate [~liqusha] The requirement looks also covered in KIP-4. Close for now

[jira] [Created] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

Jiangjie Qin created KAFKA-2076: --- Summary: Add an API to new consumer to allow user get high watermark of partitions. Key: KAFKA-2076 URL: https://issues.apache.org/jira/browse/KAFKA-2076 Project

[jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14389466#comment-14389466 ] Jiangjie Qin commented on KAFKA-2076: - [~jkreps] Totally agree that we need to t

[jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14389652#comment-14389652 ] Jiangjie Qin commented on KAFKA-2076: - Got it. Thanks for the explanation, [~jk

[jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14389839#comment-14389839 ] Jiangjie Qin commented on KAFKA-2076: - Return a map of time->offset would be

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14390958#comment-14390958 ] Jiangjie Qin commented on KAFKA-1660: - [~jkreps] Ping to see if you could help re

[jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14393516#comment-14393516 ] Jiangjie Qin commented on KAFKA-2076: - Hey [~jkreps], any more thoughts on

[jira] [Assigned] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-2076: --- Assignee: Jiangjie Qin > Add an API to new consumer to allow user get high watermark

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-07_18:18:40.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14484498#comment-14484498 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Created] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

Jiangjie Qin created KAFKA-2103: --- Summary: kafka.producer.AsyncProducerTest failure. Key: KAFKA-2103 URL: https://issues.apache.org/jira/browse/KAFKA-2103 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-10_15:08:54.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490445#comment-14490445 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Commented] (KAFKA-2102) Remove unnecessary synchronization when managing metadata

[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490624#comment-14490624 ] Jiangjie Qin commented on KAFKA-2102: - I'm with Ewen on this. We probably c

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486022#comment-14486022 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-08_14:01:12.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-2076) Add an API to new consumer to allow user get high watermark of partitions.

[ https://issues.apache.org/jira/browse/KAFKA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486359#comment-14486359 ] Jiangjie Qin commented on KAFKA-2076: - Hi [~jkreps], Actually thought about

[jira] [Commented] (KAFKA-2108) Node deleted all data and re-sync from replicas after attempted upgrade from 0.8.1.1 to 0.8.2.0

[ https://issues.apache.org/jira/browse/KAFKA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486345#comment-14486345 ] Jiangjie Qin commented on KAFKA-2108: - [~slimunholyone] sent me some logs off

[jira] [Commented] (KAFKA-2089) MetadataTest transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492713#comment-14492713 ] Jiangjie Qin commented on KAFKA-2089: - Hey [~rsivaram], your are right. We don&#x

[jira] [Created] (KAFKA-2120) Add a request timeout to NetworkClient

Jiangjie Qin created KAFKA-2120: --- Summary: Add a request timeout to NetworkClient Key: KAFKA-2120 URL: https://issues.apache.org/jira/browse/KAFKA-2120 Project: Kafka Issue Type: New Feature

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-16_11:35:37.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498469#comment-14498469 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Status: Patch Available (was: In Progress) > Ability to call close() with a timeout on the J

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-20_17:38:22.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14504039#comment-14504039 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Created] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

Jiangjie Qin created KAFKA-2138: --- Summary: KafkaProducer does not honor the retry backoff time. Key: KAFKA-2138 URL: https://issues.apache.org/jira/browse/KAFKA-2138 Project: Kafka Issue Type

[jira] [Created] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

Jiangjie Qin created KAFKA-2139: --- Summary: Add a separate controller messge queue with higher priority on broker side Key: KAFKA-2139 URL: https://issues.apache.org/jira/browse/KAFKA-2139 Project

[jira] [Assigned] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-2139: --- Assignee: Jiangjie Qin > Add a separate controller messge queue with higher priority

[jira] [Updated] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2138: Attachment: KAFKA-2138.patch > KafkaProducer does not honor the retry backoff t

[jira] [Updated] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2138: Status: Patch Available (was: Open) > KafkaProducer does not honor the retry backoff t

[jira] [Commented] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14505955#comment-14505955 ] Jiangjie Qin commented on KAFKA-2138: - Created reviewboard https://reviews.apache

[jira] [Commented] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14506011#comment-14506011 ] Jiangjie Qin commented on KAFKA-2138: - [~junrao] [~jjkoshy] Do you think we sh

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14507480#comment-14507480 ] Jiangjie Qin commented on KAFKA-2139: - Sure, I will be glad to write a wiki and

[jira] [Updated] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2138: Attachment: KAFKA-2138_2015-04-22_17:19:33.patch > KafkaProducer does not honor the retry back

[jira] [Commented] (KAFKA-2138) KafkaProducer does not honor the retry backoff time.

[ https://issues.apache.org/jira/browse/KAFKA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14508203#comment-14508203 ] Jiangjie Qin commented on KAFKA-2138: - Updated reviewboard https://reviews.apache

[jira] [Created] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

Jiangjie Qin created KAFKA-2142: --- Summary: Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer Key: KAFKA-2142 URL: https://issues.apache.org/jira/browse/KAFKA-2142 Project

[jira] [Created] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

Jiangjie Qin created KAFKA-2150: --- Summary: FetcherThread backoff need to grab lock before wait on condition. Key: KAFKA-2150 URL: https://issues.apache.org/jira/browse/KAFKA-2150 Project: Kafka

[jira] [Commented] (KAFKA-2150) FetcherThread backoff need to grab lock before wait on condition.

[ https://issues.apache.org/jira/browse/KAFKA-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512326#comment-14512326 ] Jiangjie Qin commented on KAFKA-2150: - This is introduced in KAFKA-1461. Fix sh

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Attachment: KAFKA-2142.patch > Follow-up patch for KAFKA-2138 Refactor the drain message logic

[jira] [Commented] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512637#comment-14512637 ] Jiangjie Qin commented on KAFKA-2142: - Created reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Status: Patch Available (was: Open) > Follow-up patch for KAFKA-2138 Refactor the drain mess

[jira] [Commented] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14512654#comment-14512654 ] Jiangjie Qin commented on KAFKA-2142: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Attachment: KAFKA-2142_2015-04-25_11:48:09.patch > Follow-up patch for KAFKA-2138 Refactor

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513453#comment-14513453 ] Jiangjie Qin commented on KAFKA-2139: - Hi [~jkreps][~nehanarkhede][~junrao][~jjk

[jira] [Commented] (KAFKA-2147) Unbalanced replication can cause extreme purgatory growth

[ https://issues.apache.org/jira/browse/KAFKA-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513475#comment-14513475 ] Jiangjie Qin commented on KAFKA-2147: - Sorry for not responding to you on the mai

[jira] [Commented] (KAFKA-1940) Initial checkout and build failing

[ https://issues.apache.org/jira/browse/KAFKA-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513494#comment-14513494 ] Jiangjie Qin commented on KAFKA-1940: - The kafka.producer.AsyncProducerTest fail

[jira] [Commented] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513499#comment-14513499 ] Jiangjie Qin commented on KAFKA-2103: - [~nehanarkhede] Yes, it is still failing.

[jira] [Updated] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2103: Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > kafka.producer.AsyncProducerT

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513534#comment-14513534 ] Jiangjie Qin commented on KAFKA-2139: - Hey Gwen, thanks for this really quick re

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513578#comment-14513578 ] Jiangjie Qin commented on KAFKA-2139: - Sorry for the confusion... I'm absolu

[jira] [Commented] (KAFKA-2103) kafka.producer.AsyncProducerTest failure.

[ https://issues.apache.org/jira/browse/KAFKA-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14515101#comment-14515101 ] Jiangjie Qin commented on KAFKA-2103: - Personally, I think the tests should

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14516034#comment-14516034 ] Jiangjie Qin commented on KAFKA-2139: - [~junrao], I'm actually very inte

[jira] [Commented] (KAFKA-2139) Add a separate controller messge queue with higher priority on broker side

[ https://issues.apache.org/jira/browse/KAFKA-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14516097#comment-14516097 ] Jiangjie Qin commented on KAFKA-2139: - [~jjkoshy] that is a good point. There

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14518484#comment-14518484 ] Jiangjie Qin commented on KAFKA-1660: - Thanks for the reference, Jay. Totally ag

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14520141#comment-14520141 ] Jiangjie Qin commented on KAFKA-1660: - Hi [~jkreps], I prefer the counter as

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14520557#comment-14520557 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-29_16:58:43.patch > Ability to call close() with a timeout on

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14520619#comment-14520619 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-29_17:37:51.patch > Ability to call close() with a timeout on

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Attachment: KAFKA-2142_2015-05-02_11:59:39.patch > Follow-up patch for KAFKA-2138 Refactor

[jira] [Commented] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14525408#comment-14525408 ] Jiangjie Qin commented on KAFKA-2142: - Updated reviewboard https://reviews.apache

[jira] [Commented] (KAFKA-1788) producer record can stay in RecordAccumulator forever if leader is no available

[ https://issues.apache.org/jira/browse/KAFKA-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14525421#comment-14525421 ] Jiangjie Qin commented on KAFKA-1788: - I took a shot to incorporate the solutio

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14526902#comment-14526902 ] Jiangjie Qin commented on KAFKA-1660: - [~jkreps] [~jjkoshy] ping for a re

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14526939#comment-14526939 ] Jiangjie Qin commented on KAFKA-1660: - Thanks for the quick response, [~jk

[jira] [Commented] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14527711#comment-14527711 ] Jiangjie Qin commented on KAFKA-2142: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-2142) Follow-up patch for KAFKA-2138 Refactor the drain message logic in new producer

[ https://issues.apache.org/jira/browse/KAFKA-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2142: Attachment: KAFKA-2142_2015-05-04_18:14:44.patch > Follow-up patch for KAFKA-2138 Refactor

[jira] [Created] (KAFKA-2177) Modify o.a.k.clients.NetworkClient to reuse it in controller/replica fetchers.

Jiangjie Qin created KAFKA-2177: --- Summary: Modify o.a.k.clients.NetworkClient to reuse it in controller/replica fetchers. Key: KAFKA-2177 URL: https://issues.apache.org/jira/browse/KAFKA-2177 Project

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14538801#comment-14538801 ] Jiangjie Qin commented on KAFKA-1997: - Hey [~junrao], good point. I will do that

[jira] [Created] (KAFKA-2186) Follow-up patch of KAFKA-1650

Jiangjie Qin created KAFKA-2186: --- Summary: Follow-up patch of KAFKA-1650 Key: KAFKA-2186 URL: https://issues.apache.org/jira/browse/KAFKA-2186 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2186) Follow-up patch of KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2186: Attachment: KAFKA-2186.patch > Follow-up patch of KAFKA-1

[jira] [Updated] (KAFKA-2186) Follow-up patch of KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2186: Status: Patch Available (was: Open) > Follow-up patch of KAFKA-1

[jira] [Commented] (KAFKA-2186) Follow-up patch of KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539074#comment-14539074 ] Jiangjie Qin commented on KAFKA-2186: - Created reviewboard https://reviews.apache

[jira] [Commented] (KAFKA-2176) DefaultPartitioner doesn't perform consistent hashing based on

[ https://issues.apache.org/jira/browse/KAFKA-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540784#comment-14540784 ] Jiangjie Qin commented on KAFKA-2176: - [~i_maravic], LinkedIn uses the mirror m

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540793#comment-14540793 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-05-12_14:28:53.patch > Ability to call close() with a timeout on

[jira] [Created] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

Jiangjie Qin created KAFKA-2190: --- Summary: Incorporate close(timeout) to Mirror Maker Key: KAFKA-2190 URL: https://issues.apache.org/jira/browse/KAFKA-2190 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2190: Attachment: KAFKA-2190.patch > Incorporate close(timeout) to Mirror Ma

[jira] [Updated] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2190: Status: Patch Available (was: Open) > Incorporate close(timeout) to Mirror Ma

[jira] [Commented] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544610#comment-14544610 ] Jiangjie Qin commented on KAFKA-2190: - Created reviewboard https://reviews.apache

[jira] [Commented] (KAFKA-2194) Produce request failure after Kafka + Zookeeper restart

[ https://issues.apache.org/jira/browse/KAFKA-2194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545873#comment-14545873 ] Jiangjie Qin commented on KAFKA-2194: - Any reason to start Kafka before startin

[jira] [Commented] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546524#comment-14546524 ] Jiangjie Qin commented on KAFKA-2190: - Updated reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-2190) Incorporate close(timeout) to Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2190: Attachment: KAFKA-2190_2015-05-15_19:50:42.patch > Incorporate close(timeout) to Mirror Ma

[jira] [Commented] (KAFKA-1778) Create new re-elect controller admin function

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14548343#comment-14548343 ] Jiangjie Qin commented on KAFKA-1778: - Hey [~joestein], I'm a little bit

[jira] [Created] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

Jiangjie Qin created KAFKA-2200: --- Summary: kafkaProducer.send() should not call callback.onCompletion() Key: KAFKA-2200 URL: https://issues.apache.org/jira/browse/KAFKA-2200 Project: Kafka

[jira] [Updated] (KAFKA-2186) Follow-up patch of KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2186: Attachment: KAFKA-2186.patch > Follow-up patch of KAFKA-1

[jira] [Commented] (KAFKA-2186) Follow-up patch of KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14555145#comment-14555145 ] Jiangjie Qin commented on KAFKA-2186: - Created reviewboard https://reviews.apache

[jira] [Updated] (KAFKA-2186) Follow-up patch of KAFKA-1650

[ https://issues.apache.org/jira/browse/KAFKA-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2186: Status: Patch Available (was: Reopened) > Follow-up patch of KAFKA-1

[jira] [Commented] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

[ https://issues.apache.org/jira/browse/KAFKA-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14563652#comment-14563652 ] Jiangjie Qin commented on KAFKA-2224: - Seems to be duplicate of KAFKA-1951. >

[jira] [Resolved] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

[ https://issues.apache.org/jira/browse/KAFKA-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-2224. - Resolution: Duplicate Duplicate of KAFKA-1951 > kafka-consumer-offset-checker when kafka off

[jira] [Updated] (KAFKA-1997) Refactor Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1997: Fix Version/s: 0.8.3 > Refactor Mirror Maker > - > >

[jira] [Created] (KAFKA-2246) UnknownTopicOrPartitionException should be an instance of InvalidMetadataException

Jiangjie Qin created KAFKA-2246: --- Summary: UnknownTopicOrPartitionException should be an instance of InvalidMetadataException Key: KAFKA-2246 URL: https://issues.apache.org/jira/browse/KAFKA-2246

[jira] [Updated] (KAFKA-2246) UnknownTopicOrPartitionException should be an instance of InvalidMetadataException

[ https://issues.apache.org/jira/browse/KAFKA-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2246: Attachment: KAFKA-2246.patch > UnknownTopicOrPartitionException should be an instance

[jira] [Updated] (KAFKA-2246) UnknownTopicOrPartitionException should be an instance of InvalidMetadataException

[ https://issues.apache.org/jira/browse/KAFKA-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2246: Status: Patch Available (was: Open) > UnknownTopicOrPartitionException should be an instance

[jira] [Commented] (KAFKA-2246) UnknownTopicOrPartitionException should be an instance of InvalidMetadataException

[ https://issues.apache.org/jira/browse/KAFKA-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14571604#comment-14571604 ] Jiangjie Qin commented on KAFKA-2246: - Created reviewboard https://reviews.apache

[jira] [Created] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

Jiangjie Qin created KAFKA-4381: --- Summary: Add per partition lag metric to KafkaConsumer. Key: KAFKA-4381 URL: https://issues.apache.org/jira/browse/KAFKA-4381 Project: Kafka Issue Type: Task

[jira] [Work started] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4381 started by Jiangjie Qin. --- > Add per partition lag metric to KafkaConsu

[jira] [Commented] (KAFKA-4381) Add per partition lag metric to KafkaConsumer.

[ https://issues.apache.org/jira/browse/KAFKA-4381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15638178#comment-15638178 ] Jiangjie Qin commented on KAFKA-4381: - [~hachikuji] [~junrao] [~guozhang] [~ew

[jira] [Commented] (KAFKA-4384) ReplicaFetcherThread stopped after ReplicaFetcherThread received a corrupted message

[ https://issues.apache.org/jira/browse/KAFKA-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15641511#comment-15641511 ] Jiangjie Qin commented on KAFKA-4384: - [~junhe] Thanks for reporting the issue.

<    1   2   3   4   5   6   7   8   9   10   >