[jira] [Created] (KAFKA-1506) Cancel kafka-reassign-partitions Job

Paul Lung created KAFKA-1506: Summary: Cancel kafka-reassign-partitions Job Key: KAFKA-1506 URL: https://issues.apache.org/jira/browse/KAFKA-1506 Project: Kafka Issue Type: New Feature

Announcing Kafka Web Console v2.0.0

Announcing the second major release of Kafka Web Console: https://github.com/claudemamo/kafka-web-console/releases/tag/v2.0.0. Highlights: - I've borrowed some ideas from Kafka Offset Monitor and added graphs to show the history of consumers offsets and lag as well as message throughput - Added

Re: Announcing Kafka Web Console v2.0.0

Awesome Claude, thanks! /*** Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop http://www.twitter.com/allthingshadoop / On Tue, Jun

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042234#comment-14042234 ] Rajasekar Elango commented on KAFKA-1477: - [~lindong] It doesn't look like review

[jira] [Commented] (KAFKA-1506) Cancel kafka-reassign-partitions Job

[ https://issues.apache.org/jira/browse/KAFKA-1506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042249#comment-14042249 ] Guozhang Wang commented on KAFKA-1506: -- Any exceptions/errors you saw in the

[jira] [Commented] (KAFKA-1504) Replica is unable to update ISR

[ https://issues.apache.org/jira/browse/KAFKA-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042245#comment-14042245 ] Guozhang Wang commented on KAFKA-1504: -- This may be due to KAFKA-1382. You can

[jira] [Issue Comment Deleted] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Comment: was deleted (was: Created reviewboard against branch transactional_messaging) add

[jira] [Issue Comment Deleted] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Comment: was deleted (was: Created reviewboard https://reviews.apache.org/r/22905/diff/ against branch

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Attachment: (was: KAFKA-1477.patch) add authentication layer and initial JKS x509 implementation for

[jira] [Updated] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1477: Attachment: (was: KAFKA-1477.patch) add authentication layer and initial JKS x509 implementation for

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042255#comment-14042255 ] Dong Lin commented on KAFKA-1477: - Rajasekar, I have submitted to this JIRA by mistake.

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042258#comment-14042258 ] Dong Lin commented on KAFKA-1477: - Hey Rajasekar, I have submitted to this JIRA by

[jira] [Created] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

Luke Forehand created KAFKA-1507: Summary: Using GetOffsetShell against non-existent topic creates the topic unintentionally Key: KAFKA-1507 URL: https://issues.apache.org/jira/browse/KAFKA-1507

[jira] [Assigned] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-1507: - Assignee: Sriharsha Chintalapani Using GetOffsetShell against

Re: Review Request 22874: Fix KAFKA-1498

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22874/#review46536 --- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java

Re: Review Request 22874: Fix KAFKA-1498

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22874/#review46540 ---

Re: Review Request 22874: Fix KAFKA-1498

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22874/#review46543 ---

[jira] [Commented] (KAFKA-1506) Cancel kafka-reassign-partitions Job

[ https://issues.apache.org/jira/browse/KAFKA-1506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042423#comment-14042423 ] Paul Lung commented on KAFKA-1506: -- I’m not sure. Unfortunately I have already removed

[jira] [Updated] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1507: - Labels: newbie (was: ) Using GetOffsetShell against non-existent topic creates the topic

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042455#comment-14042455 ] Neha Narkhede commented on KAFKA-1308: -- +1 on KAFKA-1308-v2.patch. Thanks Jakob!

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042700#comment-14042700 ] Jakob Homan commented on KAFKA-1308: We're still blocked on the Samza release even

[jira] [Created] (KAFKA-1508) Scripts Break When Path Has Spaces

Tim Olson created KAFKA-1508: Summary: Scripts Break When Path Has Spaces Key: KAFKA-1508 URL: https://issues.apache.org/jira/browse/KAFKA-1508 Project: Kafka Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042744#comment-14042744 ] Joe Stein commented on KAFKA-1308: -- I am +1 to Jakob's suggestion and I can do this in a

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042749#comment-14042749 ] Joe Stein commented on KAFKA-1308: -- which patch(s) would apply to the 0.8.1.1 tag? it

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042755#comment-14042755 ] Neha Narkhede commented on KAFKA-1308: -- I'm also +1 on Jakob's suggestion. Joe,

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042775#comment-14042775 ] Jakob Homan commented on KAFKA-1308: Yes, just KAFKA-1308-2.patch (and then manually

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042776#comment-14042776 ] Jakob Homan commented on KAFKA-1308: If no one is opposed, I'll go ahead and do it

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042804#comment-14042804 ] Joe Stein commented on KAFKA-1308: -- Sounds good, I will wait for the commit to the 0.8.1

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

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14042818#comment-14042818 ] Jakob Homan commented on KAFKA-1308: I've committed this to 0.8.1. I had already

[jira] [Assigned] (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 ] Jakob Homan reassigned KAFKA-1308: -- Assignee: Jakob Homan Publish jar of test utilities to Maven

Request New Feature On Kafka 0.8.1

Hi Kafka Dev Teeam, I would like to request following features in Kafka Async Producers: 1) Ability to Inject the implementation of the Blocking Queue similar to serialize and partition class etc… I would like to inject following LIB for queue implementation. Of course wrapper upon

Monitoring Producers at Large Scale

We use Kafka as Transport Layer to transport application logs. How do we monitor Producers at large scales about 6000 boxes x 4 topic per box so roughly 24000 producers (spread across multiple data center.. we have brokers per DC). We do the monitoring based on logs. I have tried intercepting

Re: Monitoring Producers at Large Scale

Sorry I want to know you want to monitor kafka producers or kafka brokers and zookeepers ? It's seems you will want to monitor monitor Exceptions eg Leader Not Found, Queue is full, resend fail etc are kafka cluster 2014-06-25 8:20 GMT+08:00 Bhavesh Mistry mistry.p.bhav...@gmail.com: We