[DISCUSS] KIP-59 - Proposal for a kafka broker command - kafka-brokers.sh

This is to start off a discussion on the above KIP at https://cwiki.apache.org/confluence/display/KAFKA/KIP-59%3A+Proposal+for+a+kafka+broker+commandThe proposal is to fill the void of a command line tool/utility that can provide information on the brokers in a Kafka cluster. The code is

Re: How to get pull request reviewed - Pull request # 1539

Hi Gwen, Thanks for the reply. I will initiate another discussion thread also. Here's the earlier thread -  https://mail-archives.apache.org/mod_mbox/kafka-users/201605.mbox/%3c545407a926534b4fbf3a62628c725a4cdcb5c...@ord-exdb102.corp.valueclick.com%3E I guess I jumped the gun and did the

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15420195#comment-15420195 ] Ben Manes commented on KAFKA-3973: -- Measuring on both put() and removeEldestEntry() is slow, as you will

[GitHub] kafka pull request #1734: KAFKA-3916: Check for disconnects properly before ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1734 KAFKA-3916: Check for disconnects properly before sending from the controller You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-3916) Connection from controller to broker disconnects

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

[jira] [Created] (KAFKA-4038) Transient failure in DeleteTopicsRequestTest.testErrorDeleteTopicRequests

Jason Gustafson created KAFKA-4038: -- Summary: Transient failure in DeleteTopicsRequestTest.testErrorDeleteTopicRequests Key: KAFKA-4038 URL: https://issues.apache.org/jira/browse/KAFKA-4038 Project:

[jira] [Commented] (KAFKA-4037) Transient failure in ConnectRestApiTest

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

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15420061#comment-15420061 ] Bill Bejeck commented on KAFKA-3973: Attaching JMH benchmark results, removing the previous

[jira] [Updated] (KAFKA-3924) Data loss due to halting when LEO is larger than leader's LEO

[ https://issues.apache.org/jira/browse/KAFKA-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Ozeritskiy updated KAFKA-3924: - Attachment: deadlock-stack > Data loss due to halting when LEO is larger than leader's

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419984#comment-15419984 ] Flavio Junqueira commented on KAFKA-1211: - [~junrao] bq. the leader needs to first wait for the

[jira] [Commented] (KAFKA-3924) Data loss due to halting when LEO is larger than leader's LEO

[ https://issues.apache.org/jira/browse/KAFKA-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419873#comment-15419873 ] Alexey Ozeritskiy commented on KAFKA-3924: -- I've got the deadlock with that patch. Stack traces:

Re: [DISCUSS] Time-based releases for Apache Kafka

To add to what Gwen said (which makes sense to me), here's a link to the Cassandra release model: http://www.planetcassandra.org/blog/cassandra-2-2-3-0-and-beyond/ It involves monthly releases, so more aggressive than what is being proposed, but they follow a tick tock model where a feature