[jira] [Comment Edited] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593116#comment-14593116 ] Honghai Chen edited comment on KAFKA-1646 at 6/19/15 6:57 AM: --

[jira] [Updated] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Honghai Chen updated KAFKA-1646: Attachment: (was: KAFKA-1646_20150618_225612.patch) > Improve consumer read performance for Wind

[jira] [Commented] (KAFKA-1646) Improve consumer read performance for Windows

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

[jira] [Updated] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Honghai Chen updated KAFKA-1646: Attachment: KAFKA-1646_20150618_235231.patch > Improve consumer read performance for Windows > -

[jira] [Resolved] (KAFKA-1465) kafka-reassign-partitions.sh fails when topic name contains dash/hyphen

[ https://issues.apache.org/jira/browse/KAFKA-1465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1465. Resolution: Fixed Fix Version/s: 0.8.3 Not able to reproduce this issue on trunk. Mig

Re: Review Request 33204: Improve 1646 fix by add log.preallocate

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33204/ --- (Updated June 19, 2015, 6:53 a.m.) Review request for kafka. Bugs: KAFKA-1646

[jira] [Commented] (KAFKA-1646) Improve consumer read performance for Windows

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

[jira] [Updated] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Honghai Chen updated KAFKA-1646: Attachment: KAFKA-1646_20150618_225612.patch > Improve consumer read performance for Windows > -

Re: Review Request 33204: Improve 1646 fix by add log.preallocate

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33204/ --- (Updated June 19, 2015, 5:56 a.m.) Review request for kafka. Summary (updated

Re: Review Request 33204: Patch for KAFKA-1646 Fix2TestCasesAndLogClean

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33204/ --- (Updated June 19, 2015, 5:55 a.m.) Review request for kafka. Summary (updated

[jira] [Updated] (KAFKA-1758) corrupt recovery file prevents startup

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

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2012: --- Status: In Progress (was: Patch Available) > Broker should automatically handle corrupt index files > ---

Re: Review Request 35503: Patch for KAFKA-2012

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35503/#review88470 --- Thanks for the patch. A couple of comments below. core/src/main/sc

Re: Review Request 34789: Patch for KAFKA-2168

> On June 18, 2015, 11:13 p.m., Ewen Cheslack-Postava wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 1379 > > > > > > This doesn't handle nested calls properly, e.g

[jira] [Commented] (KAFKA-2234) Partition reassignment of a nonexistent topic prevents future reassignments

[ https://issues.apache.org/jira/browse/KAFKA-2234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592757#comment-14592757 ] Jun Rao commented on KAFKA-2234: The patch introduced a unit test failure. Checked in a tr

Re: Review Request 34789: Patch for KAFKA-2168

> On June 18, 2015, 11:13 p.m., Ewen Cheslack-Postava wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 1379 > > > > > > This doesn't handle nested calls properly, e.g

Re: Review Request 35086: add response tests for ConsumerCoordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35086/#review88462 --- Ship it! (Discussed comments offline with Onur) - Joel Koshy On

[jira] [Updated] (KAFKA-2234) Partition reassignment of a nonexistent topic prevents future reassignments

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

Re: Review Request 34789: Patch for KAFKA-2168

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34789/#review88451 --- clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsum

[jira] [Updated] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2265: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch. This is great finding

Re: Review Request 34789: Patch for KAFKA-2168

> On June 18, 2015, 9:59 p.m., Jay Kreps wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 1364 > > > > > > This seems like one of these things that is clever but inva

Re: Review Request 34789: Patch for KAFKA-2168

> On June 18, 2015, 9:59 p.m., Jay Kreps wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 1364 > > > > > > This seems like one of these things that is clever but inva

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

I think the only problem we came up with was that Kafka KopyKat abbreviates as KKK which is not ideal in the US. Copykat would still be googlable without that issue. :-) -Jay On Thu, Jun 18, 2015 at 1:20 PM, Otis Gospodnetic < otis.gospodne...@gmail.com> wrote: > Just a comment on the name. Kopy

[jira] [Reopened] (KAFKA-2249) KafkaConfig does not preserve original Properties

[ https://issues.apache.org/jira/browse/KAFKA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reopened KAFKA-2249: [~gwenshap], with this patch, an issue that I realized is that we print out the configs in LogConfig for every

Re: Review Request 34789: Patch for KAFKA-2168

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34789/#review88441 --- clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsum

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2168: --- Attachment: KAFKA-2168_2015-06-18_14:39:36.patch > New consumer poll() can block other calls l

Re: Review Request 34789: Patch for KAFKA-2168

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34789/ --- (Updated June 18, 2015, 9:40 p.m.) Review request for kafka. Bugs: KAFKA-2168

[jira] [Commented] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592582#comment-14592582 ] Jason Gustafson commented on KAFKA-2168: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2210: --- Status: In Progress (was: Patch Available) [~parth.brahmbhatt], KAFKA-2249 is now committed. Could you rebase

[jira] [Resolved] (KAFKA-2279) add a main method in LogConfig to generate topic level configs in html

[ https://issues.apache.org/jira/browse/KAFKA-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2279. Resolution: Implemented Fix Version/s: 0.8.3 This is already fixed in KAFKA-2249. > add a main metho

[jira] [Updated] (KAFKA-2249) KafkaConfig does not preserve original Properties

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

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

Just a comment on the name. KopyKat? More unique, easy to write, pronounce, remember... Otis > On Jun 18, 2015, at 13:36, Jay Kreps wrote: > > 1. We were calling the plugins connectors (which is kind of a generic way > to say either source or sink) and the framework copycat. The pro of copy

[jira] [Commented] (KAFKA-2285) Logging trait obfuscates call site information

[ https://issues.apache.org/jira/browse/KAFKA-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592415#comment-14592415 ] Grant Henke commented on KAFKA-2285: I agree. My suggestion was a way to move the call

[jira] [Commented] (KAFKA-2285) Logging trait obfuscates call site information

[ https://issues.apache.org/jira/browse/KAFKA-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592390#comment-14592390 ] E. Sammer commented on KAFKA-2285: -- The if guard isn't the issue. Any invocation of a log

[jira] [Commented] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592310#comment-14592310 ] Alexander Pakulov commented on KAFKA-1782: -- Updated reviewboard https://reviews.a

[jira] [Updated] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pakulov updated KAFKA-1782: - Attachment: KAFKA-1782_2015-06-18_11:52:49.patch > Junit3 Misusage > --- > >

Re: Review Request 35615: Patch for KAFKA-1782

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35615/ --- (Updated June 18, 2015, 6:53 p.m.) Review request for kafka. Bugs: KAFKA-1782

Re: Review Request 35615: Patch for KAFKA-1782

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35615/ --- (Updated June 18, 2015, 6:39 p.m.) Review request for kafka. Bugs: KAFKA-1782

[jira] [Updated] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pakulov updated KAFKA-1782: - Attachment: KAFKA-1782.patch > Junit3 Misusage > --- > > Key:

[jira] [Updated] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pakulov updated KAFKA-1782: - Status: Patch Available (was: Open) > Junit3 Misusage > --- > >

[jira] [Commented] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592268#comment-14592268 ] Alexander Pakulov commented on KAFKA-1782: -- Created reviewboard https://reviews.a

Review Request 35615: Patch for KAFKA-1782

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

Re: Review Request 35086: add response tests for ConsumerCoordinator

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35086/#review88131 --- This looks good to me. Just have a minor comment below, and one orth

[jira] [Created] (KAFKA-2286) Cannot produce messages remotely: No partition metadata for topic test due to kafka.common.LeaderNotAvailableException

Mike Bridge created KAFKA-2286: -- Summary: Cannot produce messages remotely: No partition metadata for topic test due to kafka.common.LeaderNotAvailableException Key: KAFKA-2286 URL: https://issues.apache.org/jira/bro

Re: [DISCUSS] KIP-26 - Add Copycat, a connector framework for data import/export

1. We were calling the plugins connectors (which is kind of a generic way to say either source or sink) and the framework copycat. The pro of copycat is it is kind of fun. The con is that it doesn't really say what it does. The Kafka Connector Framework would be a duller but more intuitive name, bu

[jira] [Commented] (KAFKA-2285) Logging trait obfuscates call site information

[ https://issues.apache.org/jira/browse/KAFKA-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591990#comment-14591990 ] Grant Henke commented on KAFKA-2285: It looks like it's where the call to _logger.*_ i

[jira] [Comment Edited] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591976#comment-14591976 ] Manikumar Reddy edited comment on KAFKA-2265 at 6/18/15 3:36 PM: ---

[jira] [Commented] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591976#comment-14591976 ] Manikumar Reddy commented on KAFKA-2265: For each partition, we are parsing /brok

[jira] [Commented] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591963#comment-14591963 ] Manikumar Reddy commented on KAFKA-2265: Created reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2265: --- Assignee: Manikumar Reddy Status: Patch Available (was: Open) > creating a topic with l

[jira] [Updated] (KAFKA-2265) creating a topic with large number of partitions takes a long time

[ https://issues.apache.org/jira/browse/KAFKA-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2265: --- Attachment: KAFKA-2265.patch > creating a topic with large number of partitions takes a long t

Review Request 35610: Patch for KAFKA-2265

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

[jira] [Updated] (KAFKA-2285) Logging trait obfuscates call site information

[ https://issues.apache.org/jira/browse/KAFKA-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] E. Sammer updated KAFKA-2285: - Summary: Logging trait obfuscates call site information (was: Logging trait destroy call site information

[jira] [Created] (KAFKA-2285) Logging trait destroy call site information

E. Sammer created KAFKA-2285: Summary: Logging trait destroy call site information Key: KAFKA-2285 URL: https://issues.apache.org/jira/browse/KAFKA-2285 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-2284) ConsumerRebalanceListener receives wrong type in partitionOwnership values

E. Sammer created KAFKA-2284: Summary: ConsumerRebalanceListener receives wrong type in partitionOwnership values Key: KAFKA-2284 URL: https://issues.apache.org/jira/browse/KAFKA-2284 Project: Kafka

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591531#comment-14591531 ] Manikumar Reddy commented on KAFKA-2200: In KafkaProducer.send() method, on ApiExc