You are viewing a plain text version of this content. The canonical link for it is here.
- Re: compiling and running using intellij - posted by S Ahmed <sa...@gmail.com> on 2012/01/01 04:36:51 UTC, 1 replies.
- Incubator PMC/Board report for Jan 2012 ([ppmc]) - posted by Marvin <no...@apache.org> on 2012/01/01 14:59:48 UTC, 4 replies.
- [jira] [Commented] (KAFKA-48) Implement optional "long poll" support in fetch request - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/02 18:20:30 UTC, 0 replies.
- [jira] [Commented] (KAFKA-228) Reduce duplicate messages served by the kafka consumer for uncompressed topics to 0 - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/02 19:24:30 UTC, 3 replies.
- [jira] Subscription: outstanding kafka patches - posted by ji...@apache.org on 2012/01/02 20:00:30 UTC, 8 replies.
- [jira] [Updated] (KAFKA-229) SimpleConsumer is not logging exceptions correctly so detailed stack trace is not coming in the logs - posted by "Jay Kreps (Updated) (JIRA)" <ji...@apache.org> on 2012/01/02 21:56:36 UTC, 0 replies.
- [jira] [Commented] (KAFKA-229) SimpleConsumer is not logging exceptions correctly so detailed stack trace is not coming in the logs - posted by "Jay Kreps (Commented) (JIRA)" <ji...@apache.org> on 2012/01/02 21:56:36 UTC, 0 replies.
- [jira] [Created] (KAFKA-230) Update website documentation to include changes in 0.7.0 release - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/03 02:28:21 UTC, 0 replies.
- [jira] [Created] (KAFKA-231) avoid logging stacktrace directly - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/03 02:30:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-231) avoid logging stacktrace directly - posted by "Jun Rao (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 02:30:21 UTC, 2 replies.
- [jira] [Commented] (KAFKA-231) avoid logging stacktrace directly - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 02:40:21 UTC, 0 replies.
- [jira] [Updated] (KAFKA-230) Update website documentation to include changes in 0.7.0 release - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 02:48:20 UTC, 6 replies.
- [jira] [Commented] (KAFKA-230) Update website documentation to include changes in 0.7.0 release - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 03:44:20 UTC, 3 replies.
- [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 18:16:39 UTC, 1 replies.
- [jira] [Created] (KAFKA-232) ConsumerConnector has no access to "getOffsetsBefore" - posted by "Edward Capriolo (Created) (JIRA)" <ji...@apache.org> on 2012/01/03 19:10:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-233) The producer's load balancing logic can send requests to dead brokers, when using the async producer option - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/03 20:08:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-215) Improve system tests for the mirroring code - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 20:10:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-220) LogManager test fails on linux - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 20:10:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-218) ZOOKEEPER-961 is nasty, upgrade to zk 3.3.4 - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 20:10:40 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-219) NOTICE file should be minimal - posted by "Neha Narkhede (Resolved) (JIRA)" <ji...@apache.org> on 2012/01/03 20:14:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-224) Shouw throw exception when serializer.class if not configured for Producer - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 20:14:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-205) Audit swallowing of exceptions/throwables - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 20:16:44 UTC, 0 replies.
- [jira] [Commented] (KAFKA-205) Audit swallowing of exceptions/throwables - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 20:16:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-173) Support encoding for non ascii characters - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 20:16:45 UTC, 0 replies.
- [jira] [Updated] (KAFKA-189) Create a script for dump segment tool - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/03 20:16:45 UTC, 0 replies.
- [jira] [Commented] (KAFKA-186) no clean way to getCompressionCodec from Java-the-language - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 20:18:40 UTC, 0 replies.
- [jira] [Commented] (KAFKA-209) Remove empty directory when no log segments remain - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 20:18:41 UTC, 1 replies.
- [jira] [Commented] (KAFKA-233) The producer's load balancing logic can send requests to dead brokers, when using the async producer option - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/03 20:20:40 UTC, 0 replies.
- Introducing the newbie tag - posted by Neha Narkhede <ne...@gmail.com> on 2012/01/03 20:25:14 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-209) Remove empty directory when no log segments remain - posted by "Neha Narkhede (Resolved) (JIRA)" <ji...@apache.org> on 2012/01/03 21:28:40 UTC, 0 replies.
- Partial message when packet size = max size? - posted by Aaron Raddon <ar...@gmail.com> on 2012/01/03 23:08:28 UTC, 1 replies.
- [jira] [Updated] (KAFKA-228) Reduce duplicate messages served by the kafka consumer for uncompressed topics to 0 - posted by "Jun Rao (Updated) (JIRA)" <ji...@apache.org> on 2012/01/04 01:06:40 UTC, 2 replies.
- [jira] [Commented] (KAFKA-232) ConsumerConnector has no access to "getOffsetsBefore" - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/04 02:40:39 UTC, 5 replies.
- [ANNOUNCE] Apache Kafka 0.7.0-incubating released - posted by Neha Narkhede <ne...@gmail.com> on 2012/01/04 18:15:46 UTC, 2 replies.
- skype meeting on replication roadmap - posted by Jun Rao <ju...@gmail.com> on 2012/01/04 19:11:01 UTC, 15 replies.
- kafka directory on www.apache.org/dist/incubator - posted by Neha Narkhede <ne...@gmail.com> on 2012/01/04 22:08:49 UTC, 0 replies.
- [jira] [Commented] (KAFKA-200) Support configurable send / receive socket buffer size in server - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 00:21:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-234) Make backoff time during consumer rebalance configurable - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 01:10:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-234) Make backoff time during consumer rebalance configurable - posted by "Jun Rao (Updated) (JIRA)" <ji...@apache.org> on 2012/01/05 01:12:39 UTC, 2 replies.
- [jira] [Commented] (KAFKA-234) Make backoff time during consumer rebalance configurable - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 01:34:40 UTC, 0 replies.
- [jira] [Created] (KAFKA-235) Add a 'log.file.age' configuration parameter to force rotation of log files after they've reached a certain age - posted by "Mathias Herberts (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 15:47:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-236) Make 'autooffset.reset' accept a delay in addition to {smallest,largest} - posted by "Mathias Herberts (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 15:51:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-236) Make 'autooffset.reset' accept a delay in addition to {smallest,largest} - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 18:05:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-235) Add a 'log.file.age' configuration parameter to force rotation of log files after they've reached a certain age - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 18:07:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-50) kafka intra-cluster replication support - posted by "Jun Rao (Updated) (JIRA)" <ji...@apache.org> on 2012/01/05 18:52:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-237) create/delete ZK path for a topic in an admin tool - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 19:06:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-237) create/delete ZK path for a topic in an admin tool - posted by "Jun Rao (Updated) (JIRA)" <ji...@apache.org> on 2012/01/05 19:06:39 UTC, 5 replies.
- [jira] [Created] (KAFKA-238) add a getTopicMetaData method in broker and expose it to producer - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 19:40:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-238) add a getTopicMetaData method in broker and expose it to producer - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 19:42:39 UTC, 8 replies.
- [jira] [Created] (KAFKA-239) Wire existing producer and consumer to use the new ZK data structure - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 19:46:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-240) implement new producer and consumer request format - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/05 19:58:39 UTC, 0 replies.
- [jira] [Commented] (KAFKA-50) kafka intra-cluster replication support - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 20:06:39 UTC, 0 replies.
- [jira] [Issue Comment Edited] (KAFKA-238) add a getTopicMetaData method in broker and expose it to producer - posted by "Neha Narkhede (Issue Comment Edited) (JIRA)" <ji...@apache.org> on 2012/01/05 20:08:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-227) Add Broker Failure Test for a Single Host - posted by "John Fung (Updated) (JIRA)" <ji...@apache.org> on 2012/01/05 20:38:39 UTC, 1 replies.
- [jira] [Commented] (KAFKA-227) Add Broker Failure Test for a Single Host - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/05 21:16:40 UTC, 1 replies.
- [jira] [Updated] (KAFKA-202) Make the request processing in kafka asynchonous - posted by "Jay Kreps (Updated) (JIRA)" <ji...@apache.org> on 2012/01/05 23:02:40 UTC, 3 replies.
- KAFKA-202 - posted by Jay Kreps <ja...@gmail.com> on 2012/01/05 23:03:24 UTC, 0 replies.
- Any chance on getting Kafka published to Maven? - posted by "Alan D. Cabrera" <li...@toolazydogs.com> on 2012/01/06 01:45:27 UTC, 19 replies.
- [jira] [Created] (KAFKA-241) ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs - posted by "Patricio Echague (Created) (JIRA)" <ji...@apache.org> on 2012/01/06 01:55:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-241) ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs - posted by "Patricio Echague (Updated) (JIRA)" <ji...@apache.org> on 2012/01/06 01:57:39 UTC, 4 replies.
- [jira] [Commented] (KAFKA-202) Make the request processing in kafka asynchonous - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/06 07:03:39 UTC, 4 replies.
- [jira] [Created] (KAFKA-242) Subsequent calls of ConsumerConnector.createMessageStreams cause Consumer offset to be incorrect - posted by "David Arthur (Created) (JIRA)" <ji...@apache.org> on 2012/01/06 18:22:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-242) Subsequent calls of ConsumerConnector.createMessageStreams cause Consumer offset to be incorrect - posted by "David Arthur (Updated) (JIRA)" <ji...@apache.org> on 2012/01/06 18:24:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-243) Improve consumer connector documentation to include blocking semantics of kafka message streams - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/06 20:52:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-200) Support configurable send / receive socket buffer size in server - posted by "John Fung (Updated) (JIRA)" <ji...@apache.org> on 2012/01/06 23:26:39 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-200) Support configurable send / receive socket buffer size in server - posted by "Jun Rao (Resolved) (JIRA)" <ji...@apache.org> on 2012/01/06 23:52:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-228) Reduce duplicate messages served by the kafka consumer for uncompressed topics - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/07 01:11:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options - posted by "Stefano Santoro (Created) (JIRA)" <ji...@apache.org> on 2012/01/09 20:08:39 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-237) create/delete ZK path for a topic in an admin tool - posted by "Jun Rao (Assigned) (JIRA)" <ji...@apache.org> on 2012/01/09 20:17:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/09 20:35:46 UTC, 5 replies.
- [jira] [Created] (KAFKA-245) upgrade to zkclient 0.1 - posted by "Pierre-Yves Ritschard (Created) (JIRA)" <ji...@apache.org> on 2012/01/10 18:30:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-245) upgrade to zkclient 0.1 - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/10 19:12:39 UTC, 4 replies.
- [jira] [Issue Comment Edited] (KAFKA-202) Make the request processing in kafka asynchonous - posted by "Neha Narkhede (Issue Comment Edited) (JIRA)" <ji...@apache.org> on 2012/01/10 20:08:39 UTC, 0 replies.
- [jira] [Issue Comment Edited] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options - posted by "Stefano Santoro (Issue Comment Edited) (JIRA)" <ji...@apache.org> on 2012/01/10 21:33:40 UTC, 1 replies.
- [jira] [Commented] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options - posted by "Stefano Santoro (Commented) (JIRA)" <ji...@apache.org> on 2012/01/10 21:43:40 UTC, 5 replies.
- [jira] [Commented] (KAFKA-240) implement new producer and consumer request format - posted by "Joe Stein (Commented) (JIRA)" <ji...@apache.org> on 2012/01/10 22:23:39 UTC, 12 replies.
- [jira] [Commented] (KAFKA-10) Kafka deployment on EC2 should be WHIRR based, instead of current contrib/deploy code based solution - posted by "Pierre-Yves Ritschard (Commented) (JIRA)" <ji...@apache.org> on 2012/01/10 22:46:43 UTC, 3 replies.
- Second Tagged use case is going live this week - posted by Taylor Gautier <tg...@tagged.com> on 2012/01/10 22:49:27 UTC, 2 replies.
- [jira] [Commented] (KAFKA-218) ZOOKEEPER-961 is nasty, upgrade to zk 3.3.4 - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/10 23:48:43 UTC, 0 replies.
- [jira] [Commented] (KAFKA-245) upgrade to zkclient 0.1 - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/11 00:18:39 UTC, 3 replies.
- [jira] [Commented] (KAFKA-203) Improve Kafka internal metrics - posted by "Joe Stein (Commented) (JIRA)" <ji...@apache.org> on 2012/01/11 02:02:39 UTC, 0 replies.
- ProducerRequest changes for KAFKA-240 - posted by Joe Stein <cr...@gmail.com> on 2012/01/11 04:54:31 UTC, 1 replies.
- [jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions - posted by "Blake Matheny (Commented) (JIRA)" <ji...@apache.org> on 2012/01/11 18:19:41 UTC, 0 replies.
- Skype meeting Jan 10 - posted by Jun Rao <ju...@gmail.com> on 2012/01/11 23:51:35 UTC, 0 replies.
- [jira] [Commented] (KAFKA-237) create/delete ZK path for a topic in an admin tool - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/12 20:19:39 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-202) Make the request processing in kafka asynchonous - posted by "Neha Narkhede (Resolved) (JIRA)" <ji...@apache.org> on 2012/01/13 01:05:44 UTC, 1 replies.
- [jira] [Created] (KAFKA-246) log configuration values used - posted by "Jun Rao (Created) (JIRA)" <ji...@apache.org> on 2012/01/13 16:39:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-247) max.message.size and fetch.size defaults should be consistent - posted by "Blake Matheny (Created) (JIRA)" <ji...@apache.org> on 2012/01/13 19:22:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-246) log configuration values used - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/13 20:42:41 UTC, 0 replies.
- [jira] [Updated] (KAFKA-247) max.message.size and fetch.size defaults should be consistent - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/13 20:42:42 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-244) Improve log4j appender to use kafka.producer.Producer, and support zk.connect|broker.list options - posted by "Neha Narkhede (Assigned) (JIRA)" <ji...@apache.org> on 2012/01/13 20:56:40 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-238) add a getTopicMetaData method in broker and expose it to producer - posted by "Neha Narkhede (Assigned) (JIRA)" <ji...@apache.org> on 2012/01/13 21:26:40 UTC, 0 replies.
- [jira] [Reopened] (KAFKA-202) Make the request processing in kafka asynchonous - posted by "Jay Kreps (Reopened) (JIRA)" <ji...@apache.org> on 2012/01/13 21:50:40 UTC, 0 replies.
- [jira] [Created] (KAFKA-248) In the class kafka.producer.DefaultPartitionner the ligne key.hashCode % numPartitions may return a negative value. this is not a good thing knowing that partittion is (always) > 0. In this case an invalide partition id is thrown in the producer. - posted by "Bertrand Perrin (Created) (JIRA)" <ji...@apache.org> on 2012/01/16 12:42:42 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-248) In the class kafka.producer.DefaultPartitionner the ligne key.hashCode % numPartitions may return a negative value. this is not a good thing knowing that partittion is (always) > 0. In this case an invalide partition id is thrown in the producer. - posted by "Jun Rao (Resolved) (JIRA)" <ji...@apache.org> on 2012/01/16 16:55:39 UTC, 0 replies.
- [jira] [Work started] (KAFKA-238) add a getTopicMetaData method in broker and expose it to producer - posted by "Neha Narkhede (Work started) (JIRA)" <ji...@apache.org> on 2012/01/17 19:42:41 UTC, 0 replies.
- [jira] [Issue Comment Edited] (KAFKA-240) implement new producer and consumer request format - posted by "Joe Stein (Issue Comment Edited) (JIRA)" <ji...@apache.org> on 2012/01/18 19:57:25 UTC, 0 replies.
- [jira] [Commented] (KAFKA-193) use by name parameter helper for logging and trait to include lazy logging and refactor code to use the new LogHelper - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/19 02:10:39 UTC, 1 replies.
- [jira] [Commented] (KAFKA-241) ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs - posted by "Joel Koshy (Commented) (JIRA)" <ji...@apache.org> on 2012/01/19 02:34:39 UTC, 0 replies.
- [jira] [Created] (KAFKA-249) Separate out Kafka mirroring into a stand-alone app - posted by "Joel Koshy (Created) (JIRA)" <ji...@apache.org> on 2012/01/20 23:36:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-250) Provide consumer iterator callback handler - posted by "Joel Koshy (Created) (JIRA)" <ji...@apache.org> on 2012/01/20 23:40:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-238) add a getTopicMetaData method in broker and expose it to producer - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/21 02:12:39 UTC, 4 replies.
- [jira] [Commented] (KAFKA-41) multi-produce and multi-fetch support with replication - posted by "Prashanth Menon (Commented) (JIRA)" <ji...@apache.org> on 2012/01/23 20:43:40 UTC, 1 replies.
- [jira] [Created] (KAFKA-251) The ConsumerStats MBean's PartOwnerStats attribute is a string - posted by "Pierre-Yves Ritschard (Created) (JIRA)" <ji...@apache.org> on 2012/01/24 18:10:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-251) The ConsumerStats MBean's PartOwnerStats attribute is a string - posted by "Pierre-Yves Ritschard (Updated) (JIRA)" <ji...@apache.org> on 2012/01/24 18:10:40 UTC, 2 replies.
- [jira] [Created] (KAFKA-252) Investigate and change getOffsetsBefore API to a new, more general API getReplicaMetadata - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/24 20:32:40 UTC, 0 replies.
- [jira] [Created] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/24 20:40:40 UTC, 0 replies.
- [jira] [Created] (KAFKA-255) A tool to UPDATE Zookeeper partition-offset with input in JSONObject string - posted by "John Fung (Created) (JIRA)" <ji...@apache.org> on 2012/01/25 00:22:41 UTC, 0 replies.
- [jira] [Created] (KAFKA-254) A tool to GET Zookeeper partition-offset and output in JSONObject string - posted by "John Fung (Created) (JIRA)" <ji...@apache.org> on 2012/01/25 00:22:41 UTC, 0 replies.
- [jira] [Commented] (KAFKA-251) The ConsumerStats MBean's PartOwnerStats attribute is a string - posted by "Jun Rao (Commented) (JIRA)" <ji...@apache.org> on 2012/01/25 01:56:40 UTC, 2 replies.
- [jira] [Commented] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster - posted by "Neha Narkhede (Commented) (JIRA)" <ji...@apache.org> on 2012/01/25 01:58:40 UTC, 0 replies.
- [jira] [Created] (KAFKA-256) Bug in the consumer rebalancing logic leads to the consumer not pulling data from some partitions - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/25 20:33:40 UTC, 0 replies.
- [jira] [Created] (KAFKA-257) Hadoop producer should use software load balancer - posted by "Sam Shah (Created) (JIRA)" <ji...@apache.org> on 2012/01/26 06:55:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-257) Hadoop producer should use software load balancer - posted by "Sam Shah (Updated) (JIRA)" <ji...@apache.org> on 2012/01/26 06:57:40 UTC, 3 replies.
- [jira] [Commented] (KAFKA-257) Hadoop producer should use software load balancer - posted by "Sam Shah (Commented) (JIRA)" <ji...@apache.org> on 2012/01/26 06:59:40 UTC, 3 replies.
- [jira] [Updated] (KAFKA-256) Bug in the consumer rebalancing logic leads to the consumer not pulling data from some partitions - posted by "Neha Narkhede (Updated) (JIRA)" <ji...@apache.org> on 2012/01/26 23:27:40 UTC, 3 replies.
- [jira] [Work started] (KAFKA-256) Bug in the consumer rebalancing logic leads to the consumer not pulling data from some partitions - posted by "Neha Narkhede (Work started) (JIRA)" <ji...@apache.org> on 2012/01/26 23:27:40 UTC, 0 replies.
- [jira] [Updated] (KAFKA-254) A tool to GET Zookeeper partition-offset and output to files - posted by "John Fung (Updated) (JIRA)" <ji...@apache.org> on 2012/01/27 23:00:18 UTC, 2 replies.
- [jira] [Updated] (KAFKA-255) A tool to UPDATE Zookeeper partition-offset with input from a file - posted by "John Fung (Updated) (JIRA)" <ji...@apache.org> on 2012/01/27 23:02:10 UTC, 2 replies.
- [jira] [Commented] (KAFKA-256) Bug in the consumer rebalancing logic leads to the consumer not pulling data from some partitions - posted by "Joel Koshy (Commented) (JIRA)" <ji...@apache.org> on 2012/01/28 03:43:14 UTC, 1 replies.
- [jira] [Created] (KAFKA-258) Remove broker.id from the broker.list config in the Producer - posted by "Neha Narkhede (Created) (JIRA)" <ji...@apache.org> on 2012/01/30 01:13:10 UTC, 0 replies.
- ProducerPool - KAFKA-240 - posted by Joe Stein <cr...@gmail.com> on 2012/01/31 06:36:43 UTC, 1 replies.
- [jira] [Created] (KAFKA-259) Exception in thread "main" java.lang.NoClassDefFoundError: kafka/Kafka Caused by: java.lang.ClassNotFoundException: kafka.Kafka - posted by "Ross Crawford-d'Heureuse (Created) (JIRA)" <ji...@apache.org> on 2012/01/31 13:42:10 UTC, 0 replies.
- [jira] [Commented] (KAFKA-259) Exception in thread "main" java.lang.NoClassDefFoundError: kafka/Kafka Caused by: java.lang.ClassNotFoundException: kafka.Kafka - posted by "Joe Stein (Commented) (JIRA)" <ji...@apache.org> on 2012/01/31 15:24:10 UTC, 1 replies.
- [jira] [Updated] (KAFKA-259) Give better error message when trying to run shell scripts without having built/downloaded the jars yet - posted by "Jay Kreps (Updated) (JIRA)" <ji...@apache.org> on 2012/01/31 23:50:02 UTC, 0 replies.