[jira] [Commented] (KAFKA-2409) Have KafkaConsumer.committed() return null when there is no committed offset

[ https://issues.apache.org/jira/browse/KAFKA-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14746956#comment-14746956 ] Onur Karaman commented on KAFKA-2409: - Is this intended to go into 0.9.0.0? I'm wonder

[jira] [Commented] (KAFKA-1686) Implement SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14746853#comment-14746853 ] Sriharsha Chintalapani commented on KAFKA-1686: --- [~junrao] Yes. Will post up

[jira] [Commented] (KAFKA-1686) Implement SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14746831#comment-14746831 ] Jun Rao commented on KAFKA-1686: [~harsha_ch], are you still working on this jira? Also, w

[jira] [Updated] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-2120: --- Attachment: KAFKA-2120_2015-09-15_18:57:20.patch > Add a request timeout to NetworkClient > --

Re: Review Request 36858: Patch for KAFKA-2120

> On Aug. 26, 2015, 8:20 p.m., Joel Koshy wrote: > > clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java, > > line 230 > > > > > > This logic is a bit confusing. Is this block necessary here?

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1474#comment-1474 ] Mayuresh Gharat commented on KAFKA-2120: Updated reviewboard https://reviews.apach

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/ --- (Updated Sept. 16, 2015, 1:57 a.m.) Review request for kafka. Bugs: KAFKA-212

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/#review99098 --- Looks good overall - only have minor comments. Got this compilation

Re: 0.9.0.0 remaining jiras

I'd be interested to see: https://issues.apache.org/jira/browse/KAFKA-2434 (has patch available, we will be using 'old' consumer for some time) https://issues.apache.org/jira/browse/KAFKA-2125 (seems rather serious, unclear if no longer relevant with new code?) https://issues.apache.org/jira/bro

Re: 0.9.0.0 remaining jiras

Yep, It looks like this was only communicated originally to the dev list (and not the users list), so it wasn't obvious to all! Thanks, Jason On Mon, Sep 14, 2015 at 12:43 AM, Stevo Slavić wrote: > Hello Jason, > > Maybe this answers your question: > > http://mail-archives.apache.org/mod_mbox

[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=14746264#comment-14746264 ] Allen Wang commented on KAFKA-1215: --- [~aauradkar] [~junrao] [~jkreps] My apache confluen

[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=14745803#comment-14745803 ] Aditya Auradkar commented on KAFKA-1215: [~allenxwang] One of the committers can p

[GitHub] kafka pull request: MINOR: Make SenderMetrics class private with p...

GitHub user rajatvig opened a pull request: https://github.com/apache/kafka/pull/219 MINOR: Make SenderMetrics class private with private final members to reduce accessibility of the inner class. You can merge this pull request into a Git repository by running: $ git pull https

[jira] [Commented] (KAFKA-2318) replica manager repeatedly tries to fetch from partitions already moved during controlled shutdown

[ https://issues.apache.org/jira/browse/KAFKA-2318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745667#comment-14745667 ] Jaya Meghani commented on KAFKA-2318: - [~becket_qin] I am facing the same issue and un

[jira] [Updated] (KAFKA-2514) change default JVM options in kafka-run-class.sh

[ https://issues.apache.org/jira/browse/KAFKA-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2514: --- Status: Patch Available (was: Open) > change default JVM options in kafka-run-class.sh >

[jira] [Assigned] (KAFKA-2514) change default JVM options in kafka-run-class.sh

[ https://issues.apache.org/jira/browse/KAFKA-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-2514: -- Assignee: Manikumar Reddy > change default JVM options in kafka-run-class.sh >

[GitHub] kafka pull request: KAFKA-2514: change default JVM options in kafk...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/218 KAFKA-2514: change default JVM options in kafka-run-class.sh. GC is set to G1 collector. You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkredd

[jira] [Commented] (KAFKA-2514) change default JVM options in kafka-run-class.sh

[ https://issues.apache.org/jira/browse/KAFKA-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745454#comment-14745454 ] ASF GitHub Bot commented on KAFKA-2514: --- GitHub user omkreddy opened a pull request:

[jira] [Created] (KAFKA-2551) Unclean leader election docs outdated

Stevo Slavic created KAFKA-2551: --- Summary: Unclean leader election docs outdated Key: KAFKA-2551 URL: https://issues.apache.org/jira/browse/KAFKA-2551 Project: Kafka Issue Type: Bug C

Re: KAFKA-2364 migrate docs from SVN to git

Hi Gwen, We need to create new branch named "asf-site" in new git repository[1]. This is requirement from Apache Infra for git based websites [2]. After creating new branch, we will the copy the existing to svn repo contents to new branch. 1. https://git-wip-us.apache.org/repos/asf/kafka-site.

[jira] [Commented] (KAFKA-2213) Log cleaner should write compacted messages using configured compression type

[ https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745350#comment-14745350 ] Manikumar Reddy commented on KAFKA-2213: [~jjkoshy] Pinging for review. Can we in

[jira] [Created] (KAFKA-2550) [Kafka][0.8.2.1][Performance]When there are a lot of partition under a Topic, there are serious performance degradation.

yanwei created KAFKA-2550: - Summary: [Kafka][0.8.2.1][Performance]When there are a lot of partition under a Topic, there are serious performance degradation. Key: KAFKA-2550 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Updated] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties

[ https://issues.apache.org/jira/browse/KAFKA-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing updated KAFKA-2394: Attachment: log4j.properties.patch this patch is to add rollingAppender for log4j.properties; by using rolli

[jira] [Updated] (KAFKA-2394) Use RollingFileAppender by default in log4j.properties

[ https://issues.apache.org/jira/browse/KAFKA-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing updated KAFKA-2394: Reviewer: Jason Gustafson Status: Patch Available (was: Open) i think it is appropriate to add some R

Jenkins build is back to normal : Kafka-trunk #622

See

[jira] [Commented] (KAFKA-2106) Partition balance tool between borkers

[ https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14744999#comment-14744999 ] Stevo Slavic commented on KAFKA-2106: - This one is nice to have for 0.9.0.0 release.

[jira] [Updated] (KAFKA-2106) Partition balance tool between borkers

[ https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-2106: Fix Version/s: 0.9.0.0 > Partition balance tool between borkers > --

[jira] [Updated] (KAFKA-2106) Partition balance tool between borkers

[ https://issues.apache.org/jira/browse/KAFKA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-2106: Affects Version/s: (was: 0.9.0.0) > Partition balance tool between borkers > ---