[jira] [Updated] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1445: - Attachment: KAFKA-1445_2014-05-14_16:28:06.patch > New Producer should send all partitions that h

[jira] [Commented] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

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

Re: Review Request 21398: Fix KAFKA-1445 v2

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21398/#review43172 --- Ship it! Ship It! - Jay Kreps On May 15, 2014, 10:19 p.m., Guozh

[jira] [Created] (KAFKA-1441) Purgatory purge causes latency spikes

Jay Kreps created KAFKA-1441: Summary: Purgatory purge causes latency spikes Key: KAFKA-1441 URL: https://issues.apache.org/jira/browse/KAFKA-1441 Project: Kafka Issue Type: Bug Repor

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453_2014-05-15_19:05:16.patch > Add a channel queue jmx in Mirror Maker >

[jira] [Created] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

Guozhang Wang created KAFKA-1453: Summary: Add a channel queue jmx in Mirror Maker Key: KAFKA-1453 URL: https://issues.apache.org/jira/browse/KAFKA-1453 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1431) ConsoleConsumer - Option to clean zk consumer path

[ https://issues.apache.org/jira/browse/KAFKA-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1431: -- Attachment: KAFKA-1431.patch > ConsoleConsumer - Option to clean zk consumer pa

[jira] [Resolved] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1445. -- Resolution: Fixed Applied. > New Producer should send all partitions that have non-empty batches when

[jira] [Created] (KAFKA-1455) Expose ConsumerOffsetChecker as an api instead of being command line only

Arup Malakar created KAFKA-1455: --- Summary: Expose ConsumerOffsetChecker as an api instead of being command line only Key: KAFKA-1455 URL: https://issues.apache.org/jira/browse/KAFKA-1455 Project: Kafka

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

See

[jira] [Updated] (KAFKA-1431) ConsoleConsumer - Option to clean zk consumer path

[ https://issues.apache.org/jira/browse/KAFKA-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1431: - Resolution: Fixed Assignee: Sriharsha Chintalapani Status: Resolved (was: Patch Ava

[jira] [Commented] (KAFKA-1407) Broker can not return to ISR because of BadVersionException

[ https://issues.apache.org/jira/browse/KAFKA-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999664#comment-13999664 ] Krzysztof Ociepa commented on KAFKA-1407: - I have the same issue using the latest

Re: Review Request 21239: Patch for KAFKA-1431

> On May 15, 2014, 3:01 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/consumer/ConsoleConsumer.scala, lines 165-166 > > > > > > Since this is a command line tool, we should print the message to > > stdout, instea

Re: decoding of responses with error_codes

Just checked in KAFKA-1437, so this should no longer be an issue. I'll update the wiki as soon as the wiki is back up. On Mon, May 12, 2014 at 05:45:27PM +0200, svante karlsson wrote: > Thanks for the clarification. > > -if (errorCode == ErrorMapping.NoError) { > - coordinator.get.writeTo(bu

Re: Review Request 21491: Fix KAFKA-1453

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21491/ --- (Updated May 15, 2014, 11:57 p.m.) Review request for kafka. Bugs: KAFKA-1453

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

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

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

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

Re: Review Request 21398: Fix KAFKA-1445 v2

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21398/#review43157 --- clients/src/main/java/org/apache/kafka/clients/producer/internals/R

[jira] [Updated] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1445: - Attachment: KAFKA-1445_2014-05-15_15:15:37.patch > New Producer should send all partitions that h

[jira] [Created] (KAFKA-1454) Update for a Scala 2.11 build

Joe Stein created KAFKA-1454: Summary: Update for a Scala 2.11 build Key: KAFKA-1454 URL: https://issues.apache.org/jira/browse/KAFKA-1454 Project: Kafka Issue Type: Improvement Repor

[jira] [Created] (KAFKA-1457) Nginx Kafka Integration

darion yaphets created KAFKA-1457: - Summary: Nginx Kafka Integration Key: KAFKA-1457 URL: https://issues.apache.org/jira/browse/KAFKA-1457 Project: Kafka Issue Type: Wish Components

[jira] [Commented] (KAFKA-1437) ConsumerMetadataResponse should always include coordinator information

[ https://issues.apache.org/jira/browse/KAFKA-1437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999297#comment-13999297 ] Joel Koshy commented on KAFKA-1437: --- Thanks for the reviews - checked in, but will leave

Re: Review Request 21491: Follow-up KAFKA-1453

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21491/ --- (Updated May 16, 2014, 4:56 p.m.) Review request for kafka. Summary (updated)

[jira] [Commented] (KAFKA-1449) Extend wire protocol to allow CRC32C

[ https://issues.apache.org/jira/browse/KAFKA-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999157#comment-13999157 ] Albert Strasheim commented on KAFKA-1449: - Maybe MagicByte also needs to increment

[jira] [Resolved] (KAFKA-1454) Update for a Scala 2.11 build

[ https://issues.apache.org/jira/browse/KAFKA-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein resolved KAFKA-1454. -- Resolution: Not a Problem just tested a Scala 2.11.0 project and it worked with the 'org.apache.kafka:

Review Request 21491: Fix KAFKA-1453

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

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Description: We have a standalone kafka server. After several days of running we get: {nofor

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453_2014-05-16_09:56:51.patch > Add a channel queue jmx in Mirror Maker >

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Attachment: state-change.log > NoReplicaOnlineException: No replica for partition > -

Max Message Size issue

Hi Kafka Dev Group, We are using Kafka version 0.8 and I am getting following exception: WARN warn, Produce request with correlation id 1617 failed due to [rawlog,19]: kafka.common.MessageSizeTooLargeException WARN warn, Produce request with correlation id 1819 failed due to [rawlog,24]: kaf

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Priority: Critical (was: Major) > NoReplicaOnlineException: No replica for partition > -

[jira] [Created] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

Artur Denysenko created KAFKA-1460: -- Summary: NoReplicaOnlineException: No replica for partition Key: KAFKA-1460 URL: https://issues.apache.org/jira/browse/KAFKA-1460 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999328#comment-13999328 ] Jay Kreps commented on KAFKA-1445: -- Looks good to me, if no comments from others I will a

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Description: We have a standalone kafka server. After several days of running we get: {nofor

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Description: We have a standalone kafka server. After several days of running we get: {nofor

[jira] [Commented] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999449#comment-13999449 ] Neha Narkhede commented on KAFKA-1298: -- @sriharsha I'm not sure that we've fixed the

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

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

[jira] [Commented] (KAFKA-1431) ConsoleConsumer - Option to clean zk consumer path

[ https://issues.apache.org/jira/browse/KAFKA-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999341#comment-13999341 ] Neha Narkhede commented on KAFKA-1431: -- Fixed the minor comment to convert error->Sys

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453_2014-05-15_17:33:04.patch > Add a channel queue jmx in Mirror Maker >

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Description: We have a standalone kafka server. After several days of running we get: {nofor

Re: Review Request 21398: Fix KAFKA-1445 v2

> On May 15, 2014, 8:47 p.m., Jay Kreps wrote: > > clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, > > line 201 > > > > > > Instead of a List use a HashSet to avoid the O(N)

[jira] [Commented] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

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

[jira] [Created] (KAFKA-1458) kafka hanging on shutdown

James Blackburn created KAFKA-1458: -- Summary: kafka hanging on shutdown Key: KAFKA-1458 URL: https://issues.apache.org/jira/browse/KAFKA-1458 Project: Kafka Issue Type: Bug Compone

[jira] [Closed] (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 closed KAFKA-1179. Assignee: Sriharsha Chintalapani > createMessageStreams() in javaapi.ZookeeperConsumerConnector doe

Re: Failed to build Kafka using IntelliJ

Tim, Changing the scala version to 2.9.2 in gradle.properities solved the problem. Thanks a lot for the help! Regards, Sheng On Wed, May 14, 2014 at 11:43 PM, Timothy Chen wrote: > It seems like that you generated your idea files you were on a > different scala version than what you configur

[jira] [Updated] (KAFKA-1460) NoReplicaOnlineException: No replica for partition

[ https://issues.apache.org/jira/browse/KAFKA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1460: --- Description: We have a standalone kafka server. After several days of running we get: {nofor

[jira] [Commented] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14000125#comment-14000125 ] Neha Narkhede commented on KAFKA-1328: -- Updated reviewboard https://reviews.apache.or

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

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

[jira] [Created] (KAFKA-1459) kafka.tools.ConsumerOffsetChecker throws NoNodeException

Scott Clasen created KAFKA-1459: --- Summary: kafka.tools.ConsumerOffsetChecker throws NoNodeException Key: KAFKA-1459 URL: https://issues.apache.org/jira/browse/KAFKA-1459 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453_2014-05-15_17:31:57.patch > Add a channel queue jmx in Mirror Maker >

Re: Review Request 21398: Fix KAFKA-1445 v2

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21398/ --- (Updated May 15, 2014, 10:15 p.m.) Review request for kafka. Bugs: KAFKA-1445

Re: Review Request 21491: Fix KAFKA-1453

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21491/ --- (Updated May 16, 2014, 2:05 a.m.) Review request for kafka. Bugs: KAFKA-1453

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453.patch > Add a channel queue jmx in Mirror Maker >

Re: Review Request 21398: Fix KAFKA-1445 v2

> On May 15, 2014, 8:47 p.m., Jay Kreps wrote: > > clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, > > line 210 > > > > > > Is Node.UNKNOWN better than null? > > > >

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999456#comment-13999456 ] Guozhang Wang commented on KAFKA-1453: -- Updated reviewboard against branch origin/tr

[jira] [Commented] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999317#comment-13999317 ] Joel Koshy commented on KAFKA-1447: --- Do you still have the preceding log and see if cont

Re: Review Request 19731: Patch for KAFKA-1328

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19731/ --- (Updated May 16, 2014, 6:46 p.m.) Review request for kafka. Bugs: KAFKA-1328

Review Request 21243: Patch for KAFKA-1442

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

[jira] [Commented] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

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

Re: Review Request 21239: Patch for KAFKA-1431

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

[jira] [Updated] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1328: - Attachment: KAFKA-1328_2014-05-09_17:18:55.patch > Add new consumer APIs > -

Review Request 21582: Follow-up KAFKA-1453

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

Re: Max Message Size issue

>From the documentation, the correct is message.max.bytes ​Regards​ -- Lucas Zago 48 9617 6763

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (90 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1450 check invalid leader in a more robust way https://issues.apache.org/jira/browse/KAFKA-1450 KAFKA-1445 New Producer shou

[jira] [Updated] (KAFKA-1430) Purgatory redesign

[ https://issues.apache.org/jira/browse/KAFKA-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1430: - Attachment: KAFKA-1430.patch > Purgatory redesign > -- > > Key: K

Re: Review Request 21588: Fix KAFKA-1430

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21588/ --- (Updated May 16, 2014, 10:55 p.m.) Review request for kafka. Bugs: KAFKA-1430

[jira] [Resolved] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1453. Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.2 Assignee: Guozhan

[jira] [Comment Edited] (KAFKA-1407) Broker can not return to ISR because of BadVersionException

[ https://issues.apache.org/jira/browse/KAFKA-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999664#comment-13999664 ] Krzysztof Ociepa edited comment on KAFKA-1407 at 5/16/14 7:32 AM: --

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453_2014-05-15_16:57:56.patch > Add a channel queue jmx in Mirror Maker >

Re: Review Request 21398: Fix KAFKA-1445 v2

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21398/#review43122 --- clients/src/main/java/org/apache/kafka/clients/producer/internals/R

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14000421#comment-14000421 ] Jun Rao commented on KAFKA-1453: Thanks for the second follow-up patch. +1 and committed t

[jira] [Updated] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1445: - Attachment: KAFKA-1445_2014-05-15_15:19:10.patch > New Producer should send all partitions that h

Re: Review Request 21491: Fix KAFKA-1453

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21491/ --- (Updated May 16, 2014, 12:33 a.m.) Review request for kafka. Bugs: KAFKA-1453

[jira] [Created] (KAFKA-1456) Add LZ4 and LZ4C as a compression codec

Joe Stein created KAFKA-1456: Summary: Add LZ4 and LZ4C as a compression codec Key: KAFKA-1456 URL: https://issues.apache.org/jira/browse/KAFKA-1456 Project: Kafka Issue Type: Improvement

Re: Review Request 21240: Patch for KAFKA-1179

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21240/#review42547 --- Also, could you please add a unit test for this? core/src/main/sca

Review Request 21588: Fix KAFKA-1430

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

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

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

[jira] [Updated] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1453: - Attachment: KAFKA-1453.patch > Add a channel queue jmx in Mirror Maker >

[jira] [Closed] (KAFKA-1431) ConsoleConsumer - Option to clean zk consumer path

[ https://issues.apache.org/jira/browse/KAFKA-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1431. > ConsoleConsumer - Option to clean zk consumer path >

Re: Max Message Size issue

You need to change max.message.size on the brokers. Thanks, Jun On Fri, May 16, 2014 at 11:02 AM, Bhavesh Mistry wrote: > Hi Kafka Dev Group, > > We are using Kafka version 0.8 and I am getting following exception: > > > WARN warn, Produce request with correlation id 1617 failed due to > [r

[jira] [Commented] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999206#comment-13999206 ] Sriharsha Chintalapani commented on KAFKA-1298: --- I am looking to work on

[jira] [Updated] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1328: - Attachment: KAFKA-1328_2014-05-16_11:46:02.patch > Add new consumer APIs > -

Re: Review Request 21491: Fix KAFKA-1453

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21491/#review43176 --- core/src/main/scala/kafka/tools/MirrorMaker.scala

Re: Review Request 21398: Fix KAFKA-1445 v2

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21398/ --- (Updated May 15, 2014, 10:19 p.m.) Review request for kafka. Bugs: KAFKA-1445

[jira] [Commented] (KAFKA-1448) Filter-plugins for messages

[ https://issues.apache.org/jira/browse/KAFKA-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999324#comment-13999324 ] Moritz Möller commented on KAFKA-1448: -- Hi Neha, our idea was to add this filter on

[jira] [Commented] (KAFKA-1430) Purgatory redesign

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

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1455#comment-1455 ] Jun Rao commented on KAFKA-1453: Thanks for the follow-up patch. +1. Committed to trunk af

[jira] [Comment Edited] (KAFKA-1407) Broker can not return to ISR because of BadVersionException

[ https://issues.apache.org/jira/browse/KAFKA-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13999664#comment-13999664 ] Krzysztof Ociepa edited comment on KAFKA-1407 at 5/16/14 7:35 AM: --

[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: - Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patches, pushed

Re: Review Request 21239: Patch for KAFKA-1431

> On May 15, 2014, 3:01 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/consumer/ConsoleConsumer.scala, lines 165-166 > > > > > > Since this is a command line tool, we should print the message to > > stdout, instea

[jira] [Commented] (KAFKA-1453) Add a channel queue jmx in Mirror Maker

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