[jira] [Commented] (KAFKA-1605) Producer should not require metadata.broker.list

[ https://issues.apache.org/jira/browse/KAFKA-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103499#comment-14103499 ] Prashant Deva commented on KAFKA-1605: -- the point is the information can be gotten fr

[jira] [Commented] (KAFKA-1605) Producer should not require metadata.broker.list

[ https://issues.apache.org/jira/browse/KAFKA-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103498#comment-14103498 ] Prashant Deva commented on KAFKA-1605: -- the point is, a broker ip (yes i know only 1

[jira] [Commented] (KAFKA-1605) Producer should not require metadata.broker.list

[ https://issues.apache.org/jira/browse/KAFKA-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103492#comment-14103492 ] Joe Stein commented on KAFKA-1605: -- fwiw, sometimes what people do is a DNS like mybroker

[jira] [Comment Edited] (KAFKA-1605) Producer should not require metadata.broker.list

[ https://issues.apache.org/jira/browse/KAFKA-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103492#comment-14103492 ] Joe Stein edited comment on KAFKA-1605 at 8/20/14 6:36 AM: --- fwiw

[jira] [Commented] (KAFKA-1605) Producer should not require metadata.broker.list

[ https://issues.apache.org/jira/browse/KAFKA-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103490#comment-14103490 ] Joe Stein commented on KAFKA-1605: -- The metadata api handles service discovery of the bro

[jira] [Created] (KAFKA-1605) Producer should not require metadata.broker.list

Prashant Deva created KAFKA-1605: Summary: Producer should not require metadata.broker.list Key: KAFKA-1605 URL: https://issues.apache.org/jira/browse/KAFKA-1605 Project: Kafka Issue Type: Im

kafka TestUtils choosePort NoSuchMethodError

I am trying to create unit test case for Kafka with a simple call Properties props =TestUtils.createBrokerConfig(1, TestUtils.choosePort(), true); It fails on > java.lang.NoSuchMethodError: > scala.Predef$.intWrapper(I)Lscala/runtime/RichInt; > at kafka.utils.TestUtils$.choosePorts(Test

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: (was: KAFKA-1604_2014-08-19_17:28:19.patch) > System Test for Transaction Management >

Re: Review Request 24856: Patch for KAFKA-1601

> On Aug. 20, 2014, 1:31 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/consumer/ConsumerTransactionBuffer.scala, line 7 > > > > > > We should probably just grab this from TxRequestTypes in the api > > package fo

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: KAFKA-1601_2014-08-19_21:10:12.patch > ConsoleConsumer/SimpleConsumerPerformance should be tran

[jira] [Commented] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103346#comment-14103346 ] Dong Lin commented on KAFKA-1601: - Updated reviewboard https://reviews.apache.org/r/24856/

Re: Review Request 24856: Patch for KAFKA-1601

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24856/ --- (Updated Aug. 20, 2014, 4:10 a.m.) Review request for kafka. Bugs: KAFKA-1601

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103343#comment-14103343 ] Dong Lin commented on KAFKA-1604: - Updated reviewboard https://reviews.apache.org/r/24874/

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: KAFKA-1604_2014-08-19_21:07:35.patch > System Test for Transaction Management > ---

Re: Review Request 24874: Patch for KAFKA-1604

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 4:07 a.m.) Review request for kafka. Summary (updated

Re: Review Request 24874: Patch for KAFKA-1601

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 4:06 a.m.) Review request for kafka. Summary (updated

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

See

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinker0 updated KAFKA-1369: Attachment: (was: patch.diff) > snappy version update 1.1.x > --- > >

[jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest

[ https://issues.apache.org/jira/browse/KAFKA-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103285#comment-14103285 ] Gwen Shapira commented on KAFKA-1400: - Good idea. Will do that next time the issue rep

[jira] [Commented] (KAFKA-1565) Transaction manager failover handling

[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103232#comment-14103232 ] Dong Lin commented on KAFKA-1565: - Sure. The JIRA is closed. > Transaction manager failov

Re: Review Request 23569: Patch for KAFKA-1525

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23569/#review51055 --- Ship it! Ship It! - Joel Koshy On Aug. 15, 2014, 6:49 p.m., Dong

Re: Review Request 24417: Patch for KAFKA-1541

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24417/#review51054 --- Ship it! Ship It! - Joel Koshy On Aug. 6, 2014, 7:54 p.m., Raul

Re: Review Request 24856: Patch for KAFKA-1601

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24856/#review51050 --- Looks good overall, although you are probably aware of the caveats -

[jira] [Commented] (KAFKA-1565) Transaction manager failover handling

[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103205#comment-14103205 ] Raul Castro Fernandez commented on KAFKA-1565: -- If this patch is not necessar

[jira] [Updated] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1527: - Attachment: KAFKA-1527_2014-08-19_18:22:26.patch > SimpleConsumer should be trans

[jira] [Updated] (KAFKA-1569) Tool for performance and correctness of transactions end-to-end

[ https://issues.apache.org/jira/browse/KAFKA-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1569: - Summary: Tool for performance and correctness of transactions end-to-end (was: T

[jira] [Commented] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103195#comment-14103195 ] Raul Castro Fernandez commented on KAFKA-1527: -- Updated reviewboard https://r

Re: Review Request 23906: Patch for KAFKA-1527

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23906/ --- (Updated Aug. 20, 2014, 1:22 a.m.) Review request for kafka. Bugs: KAFKA-1527

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinker0 updated KAFKA-1369: Attachment: patch.diff patch.diff > snappy version update 1.1.x > -

[jira] [Updated] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1603: --- Resolution: Fixed Fix Version/s: 0.8.2 Status: Resolved (was: Patch Available) Thanks for

[jira] [Closed] (KAFKA-1582) System Test should wait for producer to finish

[ https://issues.apache.org/jira/browse/KAFKA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed KAFKA-1582. --- > System Test should wait for producer to finish > -- > >

[jira] [Closed] (KAFKA-1550) Patch review tool should use git format-patch to generate patch

[ https://issues.apache.org/jira/browse/KAFKA-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed KAFKA-1550. --- > Patch review tool should use git format-patch to generate patch > -

[jira] [Closed] (KAFKA-1565) Transaction manager failover handling

[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed KAFKA-1565. --- Merged into KAFKA-1523: Implement transaction manager module > Transaction manager failover handling > -

[jira] [Resolved] (KAFKA-1565) Transaction manager failover handling

[ https://issues.apache.org/jira/browse/KAFKA-1565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-1565. - Resolution: Duplicate Merged into KAFKA-1523: Implement transaction manager module. > Transaction manage

[jira] [Updated] (KAFKA-1523) Implement transaction manager module

[ https://issues.apache.org/jira/browse/KAFKA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1523: Description: * Entry point for transaction requests * Appends transaction control records to the transactio

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103141#comment-14103141 ] Dong Lin commented on KAFKA-1604: - Updated reviewboard https://reviews.apache.org/r/24874/

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: KAFKA-1604_2014-08-19_17:31:16.patch > System Test for Transaction Management > ---

Re: Review Request 24874: Patch for KAFKA-1604

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:31 a.m.) Review request for kafka. Bugs: KAFKA-160

[jira] [Updated] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1604: Attachment: KAFKA-1604_2014-08-19_17:28:19.patch > System Test for Transaction Management > ---

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103136#comment-14103136 ] Dong Lin commented on KAFKA-1604: - Created reviewboard https://reviews.apache.org/r/24874/

[jira] [Commented] (KAFKA-1604) System Test for Transaction Management

[ https://issues.apache.org/jira/browse/KAFKA-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103137#comment-14103137 ] Dong Lin commented on KAFKA-1604: - Updated reviewboard https://reviews.apache.org/r/24874/

Re: Review Request 24874: Patch for KAFKA-1604

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:28 a.m.) Review request for kafka. Bugs: KAFKA-160

Re: Review Request 24874: Patch for KAFKA-1604

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:19 a.m.) Review request for kafka. Summary (update

Re: Review Request 24874: Patch for KAFKA-1601

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24874/ --- (Updated Aug. 20, 2014, 12:18 a.m.) Review request for kafka. Bugs: KAFKA-160

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: (was: KAFKA-1601.patch) > ConsoleConsumer/SimpleConsumerPerformance should be transaction-a

[jira] [Commented] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14103123#comment-14103123 ] Dong Lin commented on KAFKA-1601: - Created reviewboard https://reviews.apache.org/r/24874/

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: KAFKA-1601.patch > ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware >

[jira] [Issue Comment Deleted] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

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

Review Request 24874: Patch for KAFKA-1601

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

[jira] [Created] (KAFKA-1604) System Test for Transaction Management

Dong Lin created KAFKA-1604: --- Summary: System Test for Transaction Management Key: KAFKA-1604 URL: https://issues.apache.org/jira/browse/KAFKA-1604 Project: Kafka Issue Type: Test Repor

[jira] [Updated] (KAFKA-1602) Use single error code for offset commit response

[ https://issues.apache.org/jira/browse/KAFKA-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1602: -- Description: As discussed with Joel offline, today the offset commit response contains an error code f

Re: Review Request 24869: Patch for KAFKA-1603

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24869/#review51041 --- Ship it! Ship It! - Guozhang Wang On Aug. 19, 2014, 9:50 p.m., J

[jira] [Commented] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102915#comment-14102915 ] Jiangjie Qin commented on KAFKA-1603: - Created reviewboard https://reviews.apache.org/

[jira] [Updated] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1603: Attachment: KAFKA-1603.patch > MirrorMaker consumer does not put the message key into ProducerRecor

[jira] [Updated] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

[ https://issues.apache.org/jira/browse/KAFKA-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1603: Assignee: Jiangjie Qin Status: Patch Available (was: Open) > MirrorMaker consumer does not p

Review Request 24869: Patch for KAFKA-1603

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

[jira] [Created] (KAFKA-1603) MirrorMaker consumer does not put the message key into ProducerRecord

Jiangjie Qin created KAFKA-1603: --- Summary: MirrorMaker consumer does not put the message key into ProducerRecord Key: KAFKA-1603 URL: https://issues.apache.org/jira/browse/KAFKA-1603 Project: Kafka

[jira] [Created] (KAFKA-1602) Use single error code for offset commit response

Guozhang Wang created KAFKA-1602: Summary: Use single error code for offset commit response Key: KAFKA-1602 URL: https://issues.apache.org/jira/browse/KAFKA-1602 Project: Kafka Issue Type: Bu

[jira] [Resolved] (KAFKA-1522) Transactional messaging request/response definitions

[ https://issues.apache.org/jira/browse/KAFKA-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy resolved KAFKA-1522. --- Resolution: Fixed > Transactional messaging request/response definitions > --

kafka TestUtils createBrokerConfig issue

Trying to write a unit test case for Kafka, and stuck with strange createBrokerConfig issue. on TestUtils.createBrokerConfigs(1) it gives me compilation error The method createBrokerConfigs(int, boolean) in the type TestUtils is not applicable for the arguments (int) When I looked into the scala

[jira] [Comment Edited] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102729#comment-14102729 ] Viktor Taranenko edited comment on KAFKA-1351 at 8/19/14 8:01 PM: --

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102729#comment-14102729 ] Viktor Taranenko commented on KAFKA-1351: - I was just comparing results in single

Re: Review Request 23655: Patch for KAFKA-687

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23655/#review51019 --- core/src/main/scala/kafka/consumer/ConsumerConfig.scala

[jira] [Updated] (KAFKA-687) Rebalance algorithm should consider partitions from all topics

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-687: - Status: Patch Available (was: Open) > Rebalance algorithm should consider partitions from all topics > --

[jira] [Updated] (KAFKA-687) Rebalance algorithm should consider partitions from all topics

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-687: - Attachment: KAFKA-687_2014-08-19_12:07:37.patch > Rebalance algorithm should consider partitions from all

[jira] [Commented] (KAFKA-687) Rebalance algorithm should consider partitions from all topics

[ https://issues.apache.org/jira/browse/KAFKA-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102664#comment-14102664 ] Joel Koshy commented on KAFKA-687: -- Updated reviewboard https://reviews.apache.org/r/23655

Re: Review Request 23655: Patch for KAFKA-687

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23655/ --- (Updated Aug. 19, 2014, 7:08 p.m.) Review request for kafka. Bugs: KAFKA-687

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102617#comment-14102617 ] Neha Narkhede commented on KAFKA-1558: -- [~clarkhaskins], please can you attach all th

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102600#comment-14102600 ] Neha Narkhede commented on KAFKA-1597: -- +1 on measuring the responses being sent and

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Description: Implement buffered consumer logic in ConsumerTransactionBuffer class. The class takes as inpu

[jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest

[ https://issues.apache.org/jira/browse/KAFKA-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102592#comment-14102592 ] Neha Narkhede commented on KAFKA-1400: -- [~gwenshap], to see if you are observing the

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102584#comment-14102584 ] Neha Narkhede commented on KAFKA-1351: -- Hey [~viktortnk], if you want to measure the

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Description: Implement buffered consumer logic in ConsumerTransactionBuffer class. The class takes as inpu

[jira] [Commented] (KAFKA-1600) Controller failover not working correctly.

[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102575#comment-14102575 ] Neha Narkhede commented on KAFKA-1600: -- [~dinghaifeng], thanks for reporting the issu

[jira] [Commented] (KAFKA-656) Add Quotas to Kafka

[ https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102552#comment-14102552 ] Abhinav Anand commented on KAFKA-656: - Hi [~jkreps], Thanks for the inputs. I am plan

[jira] [Commented] (KAFKA-1526) Producer performance tool should have an option to enable transactions

[ https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102543#comment-14102543 ] Raul Castro Fernandez commented on KAFKA-1526: -- Updated reviewboard https://r

[jira] [Updated] (KAFKA-1526) Producer performance tool should have an option to enable transactions

[ https://issues.apache.org/jira/browse/KAFKA-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1526: - Attachment: KAFKA-1526_2014-08-19_10:54:51.patch > Producer performance tool shou

Re: Review Request 23647: Patch for KAFKA-1526

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23647/ --- (Updated Aug. 19, 2014, 5:54 p.m.) Review request for kafka. Bugs: KAFKA-1526

[jira] [Commented] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102540#comment-14102540 ] Dong Lin commented on KAFKA-1601: - Created reviewboard https://reviews.apache.org/r/24856/

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Attachment: KAFKA-1601.patch > ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware >

Review Request 24856: Patch for KAFKA-1601

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

[jira] [Updated] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1601: Assignee: Dong Lin > ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware > --

[jira] [Created] (KAFKA-1601) ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware

Dong Lin created KAFKA-1601: --- Summary: ConsoleConsumer/SimpleConsumerPerformance should be transaction-aware Key: KAFKA-1601 URL: https://issues.apache.org/jira/browse/KAFKA-1601 Project: Kafka Is

[jira] [Updated] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1527: - Attachment: KAFKA-1527_2014-08-19_10:39:53.patch > SimpleConsumer should be trans

[jira] [Commented] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102513#comment-14102513 ] Raul Castro Fernandez commented on KAFKA-1527: -- Updated reviewboard https://r

Re: Review Request 23906: Patch for KAFKA-1527

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23906/ --- (Updated Aug. 19, 2014, 5:39 p.m.) Review request for kafka. Bugs: KAFKA-1527

[jira] [Commented] (KAFKA-1485) Upgrade to Zookeeper 3.4.6 and create "shim" for ZKCLI so system tests can run

[ https://issues.apache.org/jira/browse/KAFKA-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102495#comment-14102495 ] Gwen Shapira commented on KAFKA-1485: - Sounds good to me. The first patch attached to

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102480#comment-14102480 ] Alexis Midon commented on KAFKA-1597: - # NetworkProcessorAvgIdlePercent and RequestHa

[jira] [Commented] (KAFKA-1400) transient unit test failure in SocketServerTest

[ https://issues.apache.org/jira/browse/KAFKA-1400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102471#comment-14102471 ] Gwen Shapira commented on KAFKA-1400: - No exception is thrown. Thats the problem :) I

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102466#comment-14102466 ] Viktor Taranenko commented on KAFKA-1351: - Sorry, to clarify, I mean testing Kafka

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102420#comment-14102420 ] Guozhang Wang commented on KAFKA-1351: -- I think a simple for-loop with log.[different

[jira] [Commented] (KAFKA-1600) Controller failover not working correctly.

[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102419#comment-14102419 ] Guozhang Wang commented on KAFKA-1600: -- Hello Haifeng, Could you upload the broker a

Re: Improving the Kafka client ecosystem

Did this mailing list ever get created? Was there consensus that it did or didn't need created? -Mark > On Jul 18, 2014, at 14:34, Jay Kreps wrote: > > A question was asked in another thread about what was an effective way > to contribute to the Kafka project for people who weren't very > enth

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102245#comment-14102245 ] Jun Rao commented on KAFKA-1597: The load on the broker is currently measured by NetworkPr

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14102234#comment-14102234 ] Jun Rao commented on KAFKA-1369: Could you attach the changes as a patch to this jira? Thi

[jira] [Created] (KAFKA-1600) Controller failover not working correctly.

Ding Haifeng created KAFKA-1600: --- Summary: Controller failover not working correctly. Key: KAFKA-1600 URL: https://issues.apache.org/jira/browse/KAFKA-1600 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

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

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinker0 updated KAFKA-1369: Status: Patch Available (was: Open) https://github.com/apache/kafka/pull/31 > snappy version update 1.1.x

[GitHub] kafka pull request: KAFKA-1369 - snappy version update 1.1.x

GitHub user thinker0 opened a pull request: https://github.com/apache/kafka/pull/31 KAFKA-1369 - snappy version update 1.1.x You can merge this pull request into a Git repository by running: $ git pull https://github.com/thinker0/kafka snappy-update Alternatively you can revi

[GitHub] kafka pull request: Snappy update (RHEL4,5,6)

GitHub user thinker0 opened a pull request: https://github.com/apache/kafka/pull/30 Snappy update (RHEL4,5,6) You can merge this pull request into a Git repository by running: $ git pull https://github.com/thinker0/kafka snappy-update Alternatively you can review and apply th

  1   2   >