[jira] [Updated] (KAFKA-1583) Kafka API Refactoring

2014-10-29 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1583: -- Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.3 Status: Reso

Re: Review Request 24676: Fix KAFKA-1583

2014-10-29 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24676/#review59109 --- Ship it! Ship It! - Joel Koshy On Oct. 28, 2014, 10:09 p.m., Guo

[jira] [Commented] (KAFKA-1501) transient unit tests failures due to port already in use

2014-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14189472#comment-14189472 ] Jay Kreps commented on KAFKA-1501: -- Interesting. There is an inherent race condition in b

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14189451#comment-14189451 ] Jay Kreps commented on KAFKA-1736: -- [~kbanker]: 1. I do think this is a real problem and

Re: Compile failure going from kafka 0.8.1.1 to 0.8.2

2014-10-29 Thread Neha Narkhede
Scala 2.10.4, kafka 0.8.1.1, my old code - compiled Scala 2.10.4, kafka 0.8.2, my old code - failed If that's the case, then we probably need to fix the issue. Can you please file a JIRA? On Wed, Oct 29, 2014 at 3:15 PM, Jack Foy wrote: > On Oct 29, 2014, at 3:03 PM, Jack Foy wrote: > > On Oct

[jira] [Commented] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests and update documentation

2014-10-29 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14189231#comment-14189231 ] Guozhang Wang commented on KAFKA-1634: -- While working on this: should a retention tim

Re: Compile failure going from kafka 0.8.1.1 to 0.8.2

2014-10-29 Thread Jack Foy
On Oct 29, 2014, at 3:03 PM, Jack Foy wrote: > On Oct 29, 2014, at 1:46 PM, Neha Narkhede wrote: >> Which version of Scala did you use for Kafka 0.8.2-beta? > > The problem reproduces under both Scala 2.10.4 and Scala 2.11.2. Sorry, to be clearer: I am using SBT with the following dependency

Re: Compile failure going from kafka 0.8.1.1 to 0.8.2

2014-10-29 Thread Jack Foy
On Oct 29, 2014, at 1:46 PM, Neha Narkhede wrote: > Which version of Scala did you use for Kafka 0.8.2-beta? The problem reproduces under both Scala 2.10.4 and Scala 2.11.2. -- Jack Foy

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14189041#comment-14189041 ] Neha Narkhede commented on KAFKA-1736: -- [~kbanker] Your idea of introducing some sort

[jira] [Updated] (KAFKA-1501) transient unit tests failures due to port already in use

2014-10-29 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1501: - Attachment: KAFKA-1501-choosePorts.patch Did anyone actually verify that a port is

Re: Compile failure going from kafka 0.8.1.1 to 0.8.2

2014-10-29 Thread Neha Narkhede
Which version of Scala did you use for Kafka 0.8.2-beta? On Wed, Oct 29, 2014 at 12:40 PM, Jack Foy wrote: > My Scala project built against kafka 0.8.1.1 commits consumer offsets as > follows: > > connector.commitOffsets > > This compiles without warnings. When I bumped the library dependenc

[jira] [Commented] (KAFKA-1737) Document required ZkSerializer for ZkClient used with AdminUtils

2014-10-29 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188902#comment-14188902 ] Neha Narkhede commented on KAFKA-1737: -- Since AdminUtils is intended to be user facin

Compile failure going from kafka 0.8.1.1 to 0.8.2

2014-10-29 Thread Jack Foy
My Scala project built against kafka 0.8.1.1 commits consumer offsets as follows: connector.commitOffsets This compiles without warnings. When I bumped the library dependency to 0.8.2-beta, the compiler started emitting this error: [error] src/main/scala/com/whitepages/kafka/consumer/C

RE: Apache Kafka Consumers in java 8

2014-10-29 Thread Seshadri, Balaji
Have anybody used Kafka with Java 8 ?. -Original Message- From: Seshadri, Balaji [mailto:balaji.sesha...@dish.com] Sent: Wednesday, October 29, 2014 11:11 AM To: 'dev@kafka.apache.org'; 'us...@kafka.apache.org' Subject: Apache Kafka Consumers in java 8 Hi All, Can you please share your

[jira] [Commented] (KAFKA-1735) MemoryRecords.Iterator needs to handle partial reads from compressed stream

2014-10-29 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188799#comment-14188799 ] Guozhang Wang commented on KAFKA-1735: -- Updated reviewboard https://reviews.apache.or

[jira] [Commented] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-29 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188685#comment-14188685 ] Jiangjie Qin commented on KAFKA-1706: - Updated reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1706) Adding a byte bounded blocking queue to util.

2014-10-29 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1706: Attachment: KAFKA-1706_2014-10-29_10:57:51.patch > Adding a byte bounded blocking queue to util. > -

Re: Review Request 26755: Patch for KAFKA-1706

2014-10-29 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26755/ --- (Updated Oct. 29, 2014, 5:57 p.m.) Review request for kafka. Bugs: KAFKA-1706

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188660#comment-14188660 ] Gwen Shapira commented on KAFKA-1736: - I'm all pro-pondering :) It sounded like you a

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Kyle Banker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188648#comment-14188648 ] Kyle Banker commented on KAFKA-1736: [~gwenshap] I that sounds pretty reasonable. But

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188637#comment-14188637 ] Gwen Shapira commented on KAFKA-1736: - Agree. What I meant is - we want to add "rack a

[jira] [Updated] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Kyle Banker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Banker updated KAFKA-1736: --- Attachment: Partitioner.scala I've attached a basic implementation, along with the original, to make i

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Kyle Banker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188628#comment-14188628 ] Kyle Banker commented on KAFKA-1736: I'd like to propose one more idea: if we don't wa

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Kyle Banker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188593#comment-14188593 ] Kyle Banker commented on KAFKA-1736: [~gwenshap] For users trying to mitigate against

Apache Kafka Consumers in java 8

2014-10-29 Thread Seshadri, Balaji
Hi All, Can you please share your experiences of running Kafka Consumers/producers with Java 8 ?. Thanks, Balaji

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188581#comment-14188581 ] Gwen Shapira commented on KAFKA-1736: - My main concern with moving to a more complex a

[jira] [Commented] (KAFKA-1583) Kafka API Refactoring

2014-10-29 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188577#comment-14188577 ] Joel Koshy commented on KAFKA-1583: --- Ok cool - I will re-review the latest patch and sho

[jira] [Comment Edited] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-29 Thread Vladimir Tretyakov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188553#comment-14188553 ] Vladimir Tretyakov edited comment on KAFKA-1481 at 10/29/14 4:49 PM: ---

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

2014-10-29 Thread Kyle Banker (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188566#comment-14188566 ] Kyle Banker commented on KAFKA-1736: Clearly, it's important to think about how a part

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

2014-10-29 Thread Vladimir Tretyakov (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14188553#comment-14188553 ] Vladimir Tretyakov commented on KAFKA-1481: --- Hi Jun, thx for juicy feedback agai

[jira] [Created] (KAFKA-1737) Document required ZkSerializer for ZkClient used with AdminUtils

2014-10-29 Thread Stevo Slavic (JIRA)
Stevo Slavic created KAFKA-1737: --- Summary: Document required ZkSerializer for ZkClient used with AdminUtils Key: KAFKA-1737 URL: https://issues.apache.org/jira/browse/KAFKA-1737 Project: Kafka