[jira] [Created] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

sriram created KAFKA-1492: - Summary: Getting error when sending producer request at the broker end with a single broker Key: KAFKA-1492 URL: https://issues.apache.org/jira/browse/KAFKA-1492 Project: Kafka

[jira] [Updated] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sriram updated KAFKA-1492: -- Description: Tried to run a simple example by sending a message to a single broker . Getting error [2014-06-1

[jira] [Commented] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030787#comment-14030787 ] sriram commented on KAFKA-1492: --- When running consumer. Broker Console: [2014-06-13 11:03:4

[jira] [Commented] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030826#comment-14030826 ] sriram commented on KAFKA-1492: --- C:\software\kafka_2.9.2-0.8.1.1\bin\windows>.\kafka-list-to

[jira] [Created] (KAFKA-1493) Use a well-documented LZ4 compression format and remove redundant LZ4HC option

James Oliver created KAFKA-1493: --- Summary: Use a well-documented LZ4 compression format and remove redundant LZ4HC option Key: KAFKA-1493 URL: https://issues.apache.org/jira/browse/KAFKA-1493 Project: K

[jira] [Commented] (KAFKA-1456) Add LZ4 and LZ4C as a compression codec

[ https://issues.apache.org/jira/browse/KAFKA-1456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030858#comment-14030858 ] James Oliver commented on KAFKA-1456: - Created KAFKA-1493 > Add LZ4 and LZ4C as a com

[jira] [Commented] (KAFKA-1493) Use a well-documented LZ4 compression format and remove redundant LZ4HC option

[ https://issues.apache.org/jira/browse/KAFKA-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030908#comment-14030908 ] Albert Strasheim commented on KAFKA-1493: - What does the format look like for a Sn

[jira] [Resolved] (KAFKA-1487) add test jars to gradle build for packaging and release

[ https://issues.apache.org/jira/browse/KAFKA-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein resolved KAFKA-1487. -- Resolution: Duplicate Already a patch for this on https://issues.apache.org/jira/browse/KAFKA-1308 > a

[jira] [Comment Edited] (KAFKA-1493) Use a well-documented LZ4 compression format and remove redundant LZ4HC option

[ https://issues.apache.org/jira/browse/KAFKA-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030908#comment-14030908 ] Albert Strasheim edited comment on KAFKA-1493 at 6/13/14 5:59 PM: --

[jira] [Updated] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1308: - Priority: Blocker (was: Major) > Publish jar of test utilities to Maven > --

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14030981#comment-14030981 ] Joris Van Remoortere commented on KAFKA-1215: - [~jjkoshy] I am out till the en

Re: Kafka High Level Consumer Fail Over

We have 3 node cluster separate physical box for consumer group and consumer that died "mupd_logmon_hb_ events_sdc-q1-logstream-8-1402448850475-6521f70a". On the box, I show the above Exception. What can I configure such way, that when a partition in COnsumer Group does not have "Owner" other

Re: Kafka High Level Consumer Fail Over

They should automatically pick up the partition with no owner. Could you use kafka.tool.ConsumerOffsetChecker to verify which partition does not have an owner, and check the logs of the back-up consumers for rebalance process, any exceptions/warning there? Guozhang On Fri, Jun 13, 2014 at 12:34

Re: Kafka High Level Consumer Fail Over

HI Guozhang, We have own monitoring tool which get the data from the Zookeeper and you can see the attached screen which list no owner, but back consumer are not picking up the partition ? I had restart the java process on machine which had the above issue. Also, my previous email I have send y

Re: Kafka High Level Consumer Fail Over

I did not see any attachments in either emails? Guozhang On Fri, Jun 13, 2014 at 1:36 PM, Bhavesh Mistry wrote: > HI Guozhang, > > We have own monitoring tool which get the data from the Zookeeper and you > can see the attached screen which list no owner, but back consumer are not > picking up

[jira] [Commented] (KAFKA-1492) Getting error when sending producer request at the broker end with a single broker

[ https://issues.apache.org/jira/browse/KAFKA-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031247#comment-14031247 ] sriram commented on KAFKA-1492: --- Can some one confirm this solution is correct ? https://gi

[jira] [Commented] (KAFKA-1297) releaseTarGz target needs signing task

[ https://issues.apache.org/jira/browse/KAFKA-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031357#comment-14031357 ] Min Zhou commented on KAFKA-1297: - Hi Jun, Seems still can't work when building kafka lik

Re: Question on Kafka .8 / Logstash client

I am not sure what you are trying to achieve but here is this: https://github.com/joekiller/logstash-kafka On Thu, Jun 12, 2014 at 11:06 AM, Sutanu Das wrote: > Hi Kafka Users, > > > 1. Is there a plugin/client for Logstash for Kakfa 0.8 ? > > > 2. Is there any example of using Kafka