Re: kafka 0.8 beta release status

Just added the High Level Consumer example. On Mon, Apr 29, 2013 at 1:52 AM, Jun Rao wrote: > We have updated the 0.8 documentation in our website ( > http://kafka.apache.org/index.html). Please review the docs. We have the > following blockers for the 0.8 beta release: > > additional docs: > *

[jira] [Commented] (KAFKA-876) Produce request: Leader not local for partition [test,0] on broker 0

[ https://issues.apache.org/jira/browse/KAFKA-876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644621#comment-13644621 ] Jun Rao commented on KAFKA-876: --- It seems that the exception was caused in the following stat

[jira] [Updated] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-887: Description: We have many ways of printing log4j information for partitions making it very difficult

[jira] [Created] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

Neha Narkhede created KAFKA-887: --- Summary: Standardize logging for partition information to [%s,%d] format Key: KAFKA-887 URL: https://issues.apache.org/jira/browse/KAFKA-887 Project: Kafka Is

[jira] [Updated] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-887: Attachment: kafka-887.patch This patch has 2 changes - 1. Standardize on "partition [%s,%d]" 2. I

[jira] [Commented] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644723#comment-13644723 ] Swapnil Ghike commented on KAFKA-887: - Thanks for the cleanup. +1 > St

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644742#comment-13644742 ] Alex Gray commented on KAFKA-133: - Silly question, but I just downloaded 0.8 branch and I s

[jira] [Commented] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644749#comment-13644749 ] Neha Narkhede commented on KAFKA-887: - Thanks for the quick review, Swapnil. Can I also

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (67 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-887 Standardize logging for partition information to [%s,%d] format https://issues.apache.org/jira/browse/KAFKA-887

[jira] [Commented] (KAFKA-886) Update info on Controlled shutdown and Preferred replica election tool

[ https://issues.apache.org/jira/browse/KAFKA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644787#comment-13644787 ] Sriram Subramanian commented on KAFKA-886: -- https://cwiki.apache.org/confluence/di

[jira] [Commented] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644832#comment-13644832 ] Jun Rao commented on KAFKA-887: --- Thanks for the patch. +1. > Standardize log

[jira] [Created] (KAFKA-888) problems when shutting down the java consumer .

kacper chwialkowski created KAFKA-888: - Summary: problems when shutting down the java consumer . Key: KAFKA-888 URL: https://issues.apache.org/jira/browse/KAFKA-888 Project: Kafka Issue T

[jira] [Commented] (KAFKA-886) Update info on Controlled shutdown and Preferred replica election tool

[ https://issues.apache.org/jira/browse/KAFKA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644863#comment-13644863 ] Jun Rao commented on KAFKA-886: --- Thanks for the write-up. Some comments. 1. It would be usef

[jira] [Commented] (KAFKA-888) problems when shutting down the java consumer .

[ https://issues.apache.org/jira/browse/KAFKA-888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13644929#comment-13644929 ] Jun Rao commented on KAFKA-888: --- This logging itself is ok. We interrupt the fetcher thread w

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13645052#comment-13645052 ] Jun Rao commented on KAFKA-133: --- Have you tried the following as listed in earlier comments?

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13645053#comment-13645053 ] Scott Carey commented on KAFKA-133: --- The build is using SBT, whic is using Ivy behind the

[jira] [Created] (KAFKA-889) Add mbeans to track socket server's response queue size in addition to request queue size

Neha Narkhede created KAFKA-889: --- Summary: Add mbeans to track socket server's response queue size in addition to request queue size Key: KAFKA-889 URL: https://issues.apache.org/jira/browse/KAFKA-889 P

[jira] [Updated] (KAFKA-889) Add mbeans to track socket server's response queue size in addition to request queue size

[ https://issues.apache.org/jira/browse/KAFKA-889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-889: Status: Patch Available (was: Open) > Add mbeans to track socket server's response queue size i

[jira] [Updated] (KAFKA-889) Add mbeans to track socket server's response queue size in addition to request queue size

[ https://issues.apache.org/jira/browse/KAFKA-889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-889: Attachment: kafka-889.patch This patch adds one mbean per processor thread to track the response que

[jira] [Updated] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-887: Status: Patch Available (was: Open) > Standardize logging for partition information to [%s,%d]

[jira] [Updated] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-887: Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the reviews, committed

[jira] [Closed] (KAFKA-887) Standardize logging for partition information to [%s,%d] format

[ https://issues.apache.org/jira/browse/KAFKA-887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-887. --- > Standardize logging for partition information to [%s,%d] format > --

[jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository

[ https://issues.apache.org/jira/browse/KAFKA-133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13645131#comment-13645131 ] Alex Gray commented on KAFKA-133: - Thanks Scott, for the links. Just searching for "sbt s3"

[jira] [Created] (KAFKA-890) The list of brokers for fetching metadata should be shuffled

Neha Narkhede created KAFKA-890: --- Summary: The list of brokers for fetching metadata should be shuffled Key: KAFKA-890 URL: https://issues.apache.org/jira/browse/KAFKA-890 Project: Kafka Issu

[jira] [Work started] (KAFKA-890) The list of brokers for fetching metadata should be shuffled

[ https://issues.apache.org/jira/browse/KAFKA-890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-890 started by Neha Narkhede. > The list of brokers for fetching metadata should be shuffled > -

[jira] [Updated] (KAFKA-890) The list of brokers for fetching metadata should be shuffled

[ https://issues.apache.org/jira/browse/KAFKA-890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-890: Attachment: kafka-890.patch This patch shuffles the list of brokers used by both producer and consum

[jira] [Updated] (KAFKA-890) The list of brokers for fetching metadata should be shuffled

[ https://issues.apache.org/jira/browse/KAFKA-890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-890: Status: Patch Available (was: In Progress) > The list of brokers for fetching metadata should b

[jira] [Created] (KAFKA-891) Replica fetcher thread should identify its host,port in the client id

Neha Narkhede created KAFKA-891: --- Summary: Replica fetcher thread should identify its host,port in the client id Key: KAFKA-891 URL: https://issues.apache.org/jira/browse/KAFKA-891 Project: Kafka

[jira] [Updated] (KAFKA-891) Replica fetcher thread should identify its host,port in the client id

[ https://issues.apache.org/jira/browse/KAFKA-891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-891: Description: Replica fetcher thread uses the leader's broker id in the client id that it sets to sen

[jira] [Updated] (KAFKA-891) Replica fetcher thread should identify its host,port in the client id

[ https://issues.apache.org/jira/browse/KAFKA-891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-891: Labels: kafka-0.8 (was: ) > Replica fetcher thread should identify its host,port in the client