[jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately

2016-03-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208491#comment-15208491 ] Jun Rao commented on KAFKA-3296: [~thecoop1984], thanks for the results. We will need to f

[GitHub] kafka pull request: KAFKA-3442: Fix FileMessageSet iterator.

2016-03-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1112 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

2016-03-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208459#comment-15208459 ] Jun Rao commented on KAFKA-3442: [~dana.powers], this issue is fixed now. Could you verify

[jira] [Updated] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

2016-03-23 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3442: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 1112 [https:

[jira] [Commented] (KAFKA-3442) FetchResponse size exceeds max.partition.fetch.bytes

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

Fwd: Need Help

2016-03-23 Thread Vineet Salian
Hi, I am trying to run this code for consumer. import java.io.UnsupportedEncodingException; import java.nio.ByteBuffer; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Properties; import kafka.consumer.Consumer; import kafka.consumer.ConsumerConfig; import k

Messages corrupted in kafka

2016-03-23 Thread sunil kalva
Hi I am seeing few messages getting corrupted in kafka, It is not happening frequently and percentage is also very very less (less than 0.1%). Basically i am publishing thrift events in byte array format to kafka topics(with out encoding like base64), and i also see more events than i publish (i c

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

2016-03-23 Thread Michal Turek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208431#comment-15208431 ] Michal Turek commented on KAFKA-3450: - Hm, another update... workaround with {{max.blo

[jira] [Updated] (KAFKA-3434) Add old ConsumerRecord constructor for compatibility

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3434: --- Reviewer: Jun Rao > Add old ConsumerRecord constructor for compatibility > ---

[jira] [Updated] (KAFKA-3425) Add missing notes to upgrade docs

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3425: --- Summary: Add missing notes to upgrade docs (was: Add KIP-45 note to upgrade docs) > Add missing note

[jira] [Updated] (KAFKA-3425) Add missing notes to upgrade docs

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3425: --- Reviewer: Gwen Shapira > Add missing notes to upgrade docs > - > >

[jira] [Updated] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

2016-03-23 Thread Michal Turek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Turek updated KAFKA-3450: Priority: Critical (was: Minor) Priority updated from minor to critical. I have just realized that

[jira] [Created] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

2016-03-23 Thread Michal Turek (JIRA)
Michal Turek created KAFKA-3450: --- Summary: Producer blocks on send to topic that doesn't exist if auto create is disabled Key: KAFKA-3450 URL: https://issues.apache.org/jira/browse/KAFKA-3450 Project: K

[jira] [Resolved] (KAFKA-3323) Negative offsets in Log Segment Index files due to Integer overflow when compaction is enabled

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3323. Resolution: Duplicate Closing as duplicate of KAFKA-2024 > Negative offsets in Log Segment Index fi

Re: Jenkins job for 0.10.0

2016-03-23 Thread Ismael Juma
Thanks Gwen! A quick heads up, the job was slightly changed to match the branch name: https://builds.apache.org/job/kafka-0.10.0-jdk7/ Ismael On Tue, Mar 22, 2016 at 5:43 PM, Gwen Shapira wrote: > Hi Team Kafka, > > Just a quick update - I've created a Jenkins job to test the 0.10.0 branch, >

Re: [VOTE] KIP-51 - List Connectors REST API

2016-03-23 Thread Ismael Juma
+1 (non-binding) Ismael On Tue, Mar 22, 2016 at 10:46 PM, Ewen Cheslack-Postava wrote: > Since it's pretty minimal, we'd like to squeeze it into 0.10 if possible, > and VOTE threads take 3 days, it was suggested it might make sense to just > kick off voting on this KIP immediately (and restart

[jira] [Updated] (KAFKA-3409) Mirror maker hangs indefinitely due to commit

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3409: --- Reviewer: Guozhang Wang > Mirror maker hangs indefinitely due to commit > ---

[jira] [Updated] (KAFKA-3296) All consumer reads hang indefinately

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3296: --- Fix Version/s: (was: 0.10.0.0) > All consumer reads hang indefinately > --

[jira] [Updated] (KAFKA-3296) All consumer reads hang indefinately

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3296: --- Fix Version/s: 0.10.0.0 > All consumer reads hang indefinately >

[jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately

2016-03-23 Thread Simon Cooper (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208201#comment-15208201 ] Simon Cooper commented on KAFKA-3296: - {code}Topic:__consumer_offsetsPartition

[jira] [Commented] (KAFKA-3449) Rename filterOut() to filterNot() to achieve better terminology

2016-03-23 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208170#comment-15208170 ] Ismael Juma commented on KAFKA-3449: I know we have unstable annotations, but it seems

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

2016-03-23 Thread Krzysiek Ciesielski (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208129#comment-15208129 ] Krzysiek Ciesielski commented on KAFKA-3135: [~hachikuji] Actually, this error

[jira] [Updated] (KAFKA-3449) Rename filterOut() to filterNot() to achieve better terminology

2016-03-23 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3449: Fix Version/s: 0.10.0.1 > Rename filterOut() to filterNot() to achieve better terminology >

[jira] [Created] (KAFKA-3449) Rename filterOut() to filterNot() to achieve better terminology

2016-03-23 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3449: --- Summary: Rename filterOut() to filterNot() to achieve better terminology Key: KAFKA-3449 URL: https://issues.apache.org/jira/browse/KAFKA-3449 Project: Kafka

[jira] [Commented] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

2016-03-23 Thread James Cheng (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208059#comment-15208059 ] James Cheng commented on KAFKA-3003: Would this cause large amounts of interbroker tra

<    1   2