[jira] [Updated] (KAFKA-1006) Consumer loses messages of a new topic with auto.offset.reset = largest

[ https://issues.apache.org/jira/browse/KAFKA-1006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1006: - Summary: Consumer loses messages of a new topic with auto.offset.reset = largest (was: Mirror ma

[jira] [Updated] (KAFKA-1006) Mirror maker loses messages of a new topic

[ https://issues.apache.org/jira/browse/KAFKA-1006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1006: - Description: Consumer currently uses auto.offset.reset = largest by default. If a new topic is c

Re: C++ client library for Apache Kafka v0.8+

This is great! Thanks for the contribution! -jay On Thursday, September 5, 2013, David Tompkins wrote: > I had a need for a C++ client API for Apache Kafka with support for the > new v0.8 wire protocol, and I didn’t see one out in the wild yet. So I > found some time and wrote one. You can find

[jira] [Commented] (KAFKA-1045) producer zk.connect config

[ https://issues.apache.org/jira/browse/KAFKA-1045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13759758#comment-13759758 ] Neha Narkhede commented on KAFKA-1045: -- Zookeeper is not required for the Kafka produ

C++ client library for Apache Kafka v0.8+

I had a need for a C++ client API for Apache Kafka with support for the new v0.8 wire protocol, and I didn’t see one out in the wild yet. So I found some time and wrote one. You can find it here on github: https://github.com/adobe-research/libkafka Released under an Apache 2.0 license as open s

[jira] [Created] (KAFKA-1045) producer zk.connect config

sjk created KAFKA-1045: -- Summary: producer zk.connect config Key: KAFKA-1045 URL: https://issues.apache.org/jira/browse/KAFKA-1045 Project: Kafka Issue Type: Bug Reporter: sjk java.lang.Il

[jira] [Created] (KAFKA-1044) change log4j to slf4j

sjk created KAFKA-1044: -- Summary: change log4j to slf4j Key: KAFKA-1044 URL: https://issues.apache.org/jira/browse/KAFKA-1044 Project: Kafka Issue Type: Bug Components: log Affects Versio

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (70 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1042 Fix segment flush logic https://issues.apache.org/jira/browse/KAFKA-1042 KAFKA-1038 fetch response should use e

[jira] [Created] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue

Guozhang Wang created KAFKA-1043: Summary: Time-consuming FetchRequest could block other request in the response queue Key: KAFKA-1043 URL: https://issues.apache.org/jira/browse/KAFKA-1043 Project: Ka

[jira] [Commented] (KAFKA-998) Producer should not retry on non-recoverable error codes

[ https://issues.apache.org/jira/browse/KAFKA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13759257#comment-13759257 ] Joel Koshy commented on KAFKA-998: -- Oh I thought this was for 0.8 - it does apply on trunk

[jira] [Closed] (KAFKA-1035) Add message-send-max-retries and retry-backoff-ms options to console producer

[ https://issues.apache.org/jira/browse/KAFKA-1035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-1035. -- > Add message-send-max-retries and retry-backoff-ms options to console producer > -

[jira] [Updated] (KAFKA-1035) Add message-send-max-retries and retry-backoff-ms options to console producer

[ https://issues.apache.org/jira/browse/KAFKA-1035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1035: --- Resolution: Fixed Assignee: Rajasekar Elango (was: Jun Rao) Status: Resolved (was: Patch Avail

[jira] [Commented] (KAFKA-1036) Unable to rename replication offset checkpoint in windows

[ https://issues.apache.org/jira/browse/KAFKA-1036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13759134#comment-13759134 ] Jun Rao commented on KAFKA-1036: Hi, Tim, Do you still want to provide a patch? I saw a p

[jira] [Closed] (KAFKA-1039) kafka return acks but not logging while sending messages with compression

[ https://issues.apache.org/jira/browse/KAFKA-1039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-1039. -- > kafka return acks but not logging while sending messages with compression > -

[jira] [Resolved] (KAFKA-1039) kafka return acks but not logging while sending messages with compression

[ https://issues.apache.org/jira/browse/KAFKA-1039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1039. Resolution: Duplicate Close this since it's a duplicate of kafka-1037. > kafka return acks

Re: Review Request 13908: Initial patch KAFKA-1012

> On Sept. 4, 2013, 11:58 p.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/common/ErrorMapping.scala, line 45 > > > > > > Could this error code be renamed to something like > > OffsetLoadingNotCompleteCode. Arg