[jira] [Resolved] (KAFKA-1310) Zookeeper timeout causes deadlock in Controller

[ https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1310. -- Resolution: Fixed Fixed by KAFKA-1310 > Zookeeper timeout causes deadlock in Controller >

[jira] [Commented] (KAFKA-1310) Zookeeper timeout causes deadlock in Controller

[ https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951678#comment-13951678 ] Neha Narkhede commented on KAFKA-1310: -- Very cool. Thanks for verifying that [~tnache

[jira] [Updated] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1342: - Fix Version/s: (was: 0.8.1.1) 0.8.2 > Slow controlled shutdowns can result

[jira] [Resolved] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1317. -- Resolution: Fixed Thanks for the patches, Tim! Committed to trunk and 0.8.1 branch > KafkaServ

[jira] [Commented] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951645#comment-13951645 ] Guozhang Wang commented on KAFKA-1251: -- A follow-up comment about naming: for the rat

[jira] [Updated] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1251: - Attachment: new-producer-metrics.png > Add metrics to the producer > ---

[jira] [Commented] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951608#comment-13951608 ] Joel Koshy commented on KAFKA-1342: --- KAFKA-1350 is what triggered this issue. Although w

[jira] [Created] (KAFKA-1350) Fix excessive state change logging

Joel Koshy created KAFKA-1350: - Summary: Fix excessive state change logging Key: KAFKA-1350 URL: https://issues.apache.org/jira/browse/KAFKA-1350 Project: Kafka Issue Type: Bug Affects Versio

[jira] [Commented] (KAFKA-1320) Change compression.codec to compression.type in new producer configs of system tests

[ https://issues.apache.org/jira/browse/KAFKA-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951594#comment-13951594 ] Guozhang Wang commented on KAFKA-1320: -- Created reviewboard https://reviews.apache.or

[jira] [Updated] (KAFKA-1320) Change compression.codec to compression.type in new producer configs of system tests

[ https://issues.apache.org/jira/browse/KAFKA-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1320: - Attachment: KAFKA-1320.patch > Change compression.codec to compression.type in new producer confi

Review Request 19811: Fix KAFKA-1320

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19811/ --- Review request for kafka. Bugs: KAFKA-1320 https://issues.apache.org/jira/b

[jira] [Created] (KAFKA-1349) Fatal error during KafkaServerStable startup

Pan Pan created KAFKA-1349: -- Summary: Fatal error during KafkaServerStable startup Key: KAFKA-1349 URL: https://issues.apache.org/jira/browse/KAFKA-1349 Project: Kafka Issue Type: Bug Comp

[jira] [Commented] (KAFKA-1348) Producer's Broker Discovery Interface

[ https://issues.apache.org/jira/browse/KAFKA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951532#comment-13951532 ] Jay Bae commented on KAFKA-1348: Let me explain again. Let's assume that initially, the br

[jira] [Commented] (KAFKA-1348) Producer's Broker Discovery Interface

[ https://issues.apache.org/jira/browse/KAFKA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951513#comment-13951513 ] Jay Kreps commented on KAFKA-1348: -- In the new producer the bootstrap just happens during

[jira] [Commented] (KAFKA-1348) Producer's Broker Discovery Interface

[ https://issues.apache.org/jira/browse/KAFKA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951494#comment-13951494 ] Jay Bae commented on KAFKA-1348: Sure, your plug api would work if bootstrapAddresses() is

[jira] [Commented] (KAFKA-1348) Producer's Broker Discovery Interface

[ https://issues.apache.org/jira/browse/KAFKA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951484#comment-13951484 ] Jay Kreps commented on KAFKA-1348: -- Hey Jay, The cluster actually maintains the current

[jira] [Commented] (KAFKA-1348) Producer's Broker Discovery Interface

[ https://issues.apache.org/jira/browse/KAFKA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951478#comment-13951478 ] Jay Bae commented on KAFKA-1348: Due to ephemeralness of the cloud, a list of brokers can

[jira] [Commented] (KAFKA-1310) Zookeeper timeout causes deadlock in Controller

[ https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951474#comment-13951474 ] Timothy Chen commented on KAFKA-1310: - I tried out the repro scenario described in the

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/#review38941 --- core/src/main/scala/kafka/controller/TopicDeletionManager.scala

[jira] [Commented] (KAFKA-1028) per topic configuration of preference for consistency over availability

[ https://issues.apache.org/jira/browse/KAFKA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951323#comment-13951323 ] Andrew Olson commented on KAFKA-1028: - Thanks for the info. Hopefully I'll have some t

[jira] [Updated] (KAFKA-1028) per topic configuration of preference for consistency over availability

[ https://issues.apache.org/jira/browse/KAFKA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Olson updated KAFKA-1028: Fix Version/s: 0.8.2 > per topic configuration of preference for consistency over availability > --

[jira] [Commented] (KAFKA-1348) Producer's Broker Discovery Interface

[ https://issues.apache.org/jira/browse/KAFKA-1348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951278#comment-13951278 ] Jay Kreps commented on KAFKA-1348: -- Hey Jay, 0.8.1.1 is just for critical bug fixes, but

[jira] [Created] (KAFKA-1347) Create a system test for network partitions

Jay Kreps created KAFKA-1347: Summary: Create a system test for network partitions Key: KAFKA-1347 URL: https://issues.apache.org/jira/browse/KAFKA-1347 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-1028) per topic configuration of preference for consistency over availability

[ https://issues.apache.org/jira/browse/KAFKA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950938#comment-13950938 ] Jay Kreps commented on KAFKA-1028: -- I added KAFKA-1347 for this. > per topic configurat

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/#review38902 --- Ship it! Looks great, thanks! core/src/main/scala/kafka/controlle

[jira] [Created] (KAFKA-1348) Producer's Broker Discovery Interface

Jay Bae created KAFKA-1348: -- Summary: Producer's Broker Discovery Interface Key: KAFKA-1348 URL: https://issues.apache.org/jira/browse/KAFKA-1348 Project: Kafka Issue Type: Improvement Com

[jira] [Commented] (KAFKA-1028) per topic configuration of preference for consistency over availability

[ https://issues.apache.org/jira/browse/KAFKA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950925#comment-13950925 ] Jay Kreps commented on KAFKA-1028: -- There is some information on writing system tests for

Re: Review Request 19696: Patch for KAFKA-1317

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19696/ --- (Updated March 28, 2014, 4:34 p.m.) Review request for kafka. Bugs: KAFKA-131

[jira] [Commented] (KAFKA-1343) Kafka consumer iterator thread stalls

[ https://issues.apache.org/jira/browse/KAFKA-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951102#comment-13951102 ] Guozhang Wang commented on KAFKA-1343: -- I cannot re-produce the issue, i.e. I set the

[jira] [Commented] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950991#comment-13950991 ] Timothy Chen commented on KAFKA-1317: - Updated reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1317) KafkaServer 0.8.1 not responding to .shutdown() cleanly, possibly related to TopicDeletionManager or MetricsMeter state

[ https://issues.apache.org/jira/browse/KAFKA-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timothy Chen updated KAFKA-1317: Attachment: KAFKA-1317_2014-03-28_09:34:02.patch > KafkaServer 0.8.1 not responding to .shutdown()

[jira] [Commented] (KAFKA-1345) java API to shutdown the connector by using a consumergroup id

[ https://issues.apache.org/jira/browse/KAFKA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951006#comment-13951006 ] schandr commented on KAFKA-1345: Thank youthat's what I thought so...I am keeping trac

[jira] [Closed] (KAFKA-1345) java API to shutdown the connector by using a consumergroup id

[ https://issues.apache.org/jira/browse/KAFKA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1345. > java API to shutdown the connector by using a consumergroup id >

[jira] [Commented] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950899#comment-13950899 ] Andrew Olson commented on KAFKA-1179: - Using the Java API, calling createMessageStream

[jira] [Resolved] (KAFKA-1345) java API to shutdown the connector by using a consumergroup id

[ https://issues.apache.org/jira/browse/KAFKA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1345. -- Resolution: Not A Problem > java API to shutdown the connector by using a consumergroup id > --

[jira] [Updated] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1179: - Assignee: (was: Neha Narkhede) > createMessageStreams() in javaapi.ZookeeperConsumerConnector

[jira] [Updated] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1179: - Labels: newbie usability (was: ) > createMessageStreams() in javaapi.ZookeeperConsumerConnector

[jira] [Commented] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

[ https://issues.apache.org/jira/browse/KAFKA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950918#comment-13950918 ] Neha Narkhede commented on KAFKA-1179: -- [~noslowerdna] It makes sense to throw an exc

[jira] [Commented] (KAFKA-1345) java API to shutdown the connector by using a consumergroup id

[ https://issues.apache.org/jira/browse/KAFKA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950933#comment-13950933 ] Neha Narkhede commented on KAFKA-1345: -- Currently, one consumer instance is associate

[jira] [Commented] (KAFKA-1345) java API to shutdown the connector by using a consumergroup id

[ https://issues.apache.org/jira/browse/KAFKA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950775#comment-13950775 ] schandr commented on KAFKA-1345: I have a use case where my application produces messages

[jira] [Commented] (KAFKA-1344) Kafka-console-producer.sh support snappy compression

[ https://issues.apache.org/jira/browse/KAFKA-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950513#comment-13950513 ] Kieren Hynd commented on KAFKA-1344: I think these might be the same. I've not had any