dev@kafka.apache.org, 2012-11

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Commented] (KAFKA-545) Add a Performance Suite for the Log subsystem - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/01 00:53:11 UTC, 5 replies.
- [jira] [Updated] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK - posted by "Prashanth Menon (JIRA)" <ji...@apache.org> on 2012/11/01 03:01:13 UTC, 2 replies.
- [jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/01 09:53:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-491) KafkaRequestHandler needs to handle exceptions - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/01 10:43:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/01 10:55:12 UTC, 3 replies.
- [jira] [Created] (KAFKA-598) decouple fetch size from max message size - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/01 16:37:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/01 17:39:12 UTC, 8 replies.
- [jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/01 19:01:13 UTC, 5 replies.
- [jira] Subscription: outstanding kafka patches - posted by ji...@apache.org on 2012/11/01 20:01:13 UTC, 8 replies.
- [jira] [Updated] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/01 22:50:13 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/01 22:50:13 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-546) Fix commit() in zk consumer for compressed messages - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/01 22:50:14 UTC, 0 replies.
- [jira] [Commented] (KAFKA-188) Support multiple data directories - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 01:52:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-546) Fix commit() in zk consumer for compressed messages - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/02 02:32:12 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-546) Fix commit() in zk consumer for compressed messages - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/02 02:36:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/02 03:04:12 UTC, 3 replies.
- [jira] [Closed] (KAFKA-491) KafkaRequestHandler needs to handle exceptions - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 03:08:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-491) KafkaRequestHandler needs to handle exceptions - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 03:08:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/02 03:48:12 UTC, 6 replies.
- [jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 05:34:12 UTC, 2 replies.
- [jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 05:52:12 UTC, 5 replies.
- [jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 06:06:13 UTC, 3 replies.
- Re: Maintainer system? - posted by Jun Rao <ju...@gmail.com> on 2012/11/02 06:15:02 UTC, 6 replies.
- [jira] [Commented] (KAFKA-546) Fix commit() in zk consumer for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/02 16:23:12 UTC, 2 replies.
- [jira] [Created] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/02 18:05:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/02 18:05:12 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/02 18:07:12 UTC, 1 replies.
- [jira] [Updated] (KAFKA-532) Multiple controllers can co-exist during soft failures - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/02 18:43:12 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-188) Support multiple data directories - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/02 20:03:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-188) Support multiple data directories - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/02 20:03:16 UTC, 0 replies.
- [jira] [Closed] (KAFKA-188) Support multiple data directories - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/02 20:03:17 UTC, 0 replies.
- [jira] [Created] (KAFKA-600) kafka should respond gracefully rather than crash when unable to write due to ENOSPC - posted by "Tim Stilwell (JIRA)" <ji...@apache.org> on 2012/11/02 23:56:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-600) kafka should respond gracefully rather than crash when unable to write due to ENOSPC - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/03 01:08:12 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-513) Add state change log to Kafka brokers - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/03 01:16:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-591) Add test cases to test log size retention and more - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/05 19:32:12 UTC, 13 replies.
- [jira] [Commented] (KAFKA-591) Add test cases to test log size retention and more - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/05 19:38:12 UTC, 1 replies.
- [jira] [Commented] (KAFKA-589) Clean shutdown after startup connection failure - posted by "Jason Rosenberg (JIRA)" <ji...@apache.org> on 2012/11/05 21:34:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-601) ConsumerConnector.shutdown() hangs if autocommit is enabled, and no zk available - posted by "Jason Rosenberg (JIRA)" <ji...@apache.org> on 2012/11/05 21:40:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-545) Add a Performance Suite for the Log subsystem - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/05 22:14:12 UTC, 2 replies.
- [jira] [Closed] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/06 00:12:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/06 00:12:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/06 00:40:13 UTC, 0 replies.
- [jira] [Closed] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/06 00:40:13 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-593) Empty log index file created when it shouldn't be empty - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/06 04:46:12 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-598) decouple fetch size from max message size - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/06 22:50:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/06 23:30:13 UTC, 0 replies.
- [jira] [Commented] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/06 23:32:12 UTC, 1 replies.
- [jira] [Created] (KAFKA-602) A ConsumerConnector that never receives messages does not shutdown cleanly - posted by "Jason Rosenberg (JIRA)" <ji...@apache.org> on 2012/11/07 17:07:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/08 04:26:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/08 04:28:11 UTC, 3 replies.
- [jira] [Updated] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/08 04:28:12 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/08 05:02:12 UTC, 0 replies.
- Multi Costumer and Broker - posted by rizal ramadhany <ri...@gmail.com> on 2012/11/08 05:40:52 UTC, 1 replies.
- [jira] [Closed] (KAFKA-546) Fix commit() in zk consumer for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/08 07:22:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-546) Fix commit() in zk consumer for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/08 07:22:12 UTC, 0 replies.
- Kafka stream processing framework? - posted by David Arthur <mu...@gmail.com> on 2012/11/08 16:32:38 UTC, 4 replies.
- [jira] [Created] (KAFKA-604) Add missing metrics in 0.8 - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/08 18:00:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-604) Add missing metrics in 0.8 - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/09 01:28:12 UTC, 1 replies.
- [jira] [Commented] (KAFKA-604) Add missing metrics in 0.8 - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/09 02:14:13 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/09 19:44:13 UTC, 0 replies.
- [jira] [Closed] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/09 19:44:14 UTC, 0 replies.
- [jira] [Closed] (KAFKA-591) Add test cases to test log size retention and more - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/09 23:59:13 UTC, 0 replies.
- [jira] [Created] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/10 23:31:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/10 23:43:12 UTC, 12 replies.
- [jira] [Commented] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/10 23:43:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/11 22:55:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/11 22:57:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/11 23:03:12 UTC, 2 replies.
- [jira] [Created] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/11 23:33:11 UTC, 0 replies.
- [jira] [Updated] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/11 23:41:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/11 23:45:11 UTC, 1 replies.
- [jira] [Commented] (KAFKA-133) Publish kafka jar to a public maven repository - posted by "Otis Gospodnetic (JIRA)" <ji...@apache.org> on 2012/11/12 17:37:15 UTC, 14 replies.
- [jira] [Comment Edited] (KAFKA-133) Publish kafka jar to a public maven repository - posted by "Otis Gospodnetic (JIRA)" <ji...@apache.org> on 2012/11/13 01:15:13 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/13 17:16:14 UTC, 0 replies.
- [jira] [Created] (KAFKA-608) getTopicMetadata does not respect producer config settings - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/13 19:00:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries" - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/13 19:04:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries" - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/13 19:06:11 UTC, 2 replies.
- [jira] [Created] (KAFKA-610) connect.timeout.ms seems to do the wrong thing in the producer - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/13 19:08:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-544) Retain key in producer and expose it in the consumer - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/14 06:46:11 UTC, 8 replies.
- [jira] [Commented] (KAFKA-544) Retain key in producer and expose it in the consumer - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/14 17:34:12 UTC, 6 replies.
- [jira] [Created] (KAFKA-611) Migration tool and Mirror Maker ignore mirror.topics.whitelist in config - posted by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2012/11/14 19:04:14 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/14 19:44:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/14 19:58:12 UTC, 0 replies.
- [jira] [Closed] (KAFKA-585) Remove custom metrics jar and replace with latest from metrics HEAD - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/14 20:00:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-612) move shutting down of fetcher thread out of critical path - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/14 22:36:14 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-612) move shutting down of fetcher thread out of critical path - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/14 22:36:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-612) move shutting down of fetcher thread out of critical path - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/14 22:44:12 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/15 01:30:13 UTC, 0 replies.
- [jira] [Closed] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/15 01:30:13 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 04:58:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-71) embed offset inside Message class - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 05:00:13 UTC, 0 replies.
- [jira] [Updated] (KAFKA-179) Log files always touched when broker is bounced - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 05:06:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/15 16:10:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/15 19:02:11 UTC, 0 replies.
- [jira] [Created] (KAFKA-615) Avoid fsync on log segment roll - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 22:19:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-615) Avoid fsync on log segment roll - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 22:43:12 UTC, 0 replies.
- Can a brother get a +1? - posted by Jay Kreps <ja...@gmail.com> on 2012/11/15 22:56:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-616) Implement acks=0 - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 23:13:11 UTC, 0 replies.
- [jira] [Updated] (KAFKA-616) Implement acks=0 - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 23:13:12 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-545) Add a Performance Suite for the Log subsystem - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/15 23:55:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/16 01:41:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/16 01:47:11 UTC, 0 replies.
- [jira] [Created] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/16 02:21:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/16 04:12:12 UTC, 1 replies.
- [jira] [Created] (KAFKA-619) System Test Regression 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/16 17:36:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/16 17:36:12 UTC, 2 replies.
- [jira] [Created] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker - posted by "Matthew Rathbone (JIRA)" <ji...@apache.org> on 2012/11/16 17:46:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker - posted by "Matthew Rathbone (JIRA)" <ji...@apache.org> on 2012/11/16 17:52:15 UTC, 0 replies.
- [jira] [Created] (KAFKA-621) System Test 9051 : ConsoleConsumer doesn't receives any data for 20 topics but works for 10 - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/16 18:40:16 UTC, 0 replies.
- [jira] [Updated] (KAFKA-621) System Test 9051 : ConsoleConsumer doesn't receives any data for 20 topics but works for 10 - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/16 18:44:11 UTC, 0 replies.
- [jira] [Closed] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/16 20:40:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/16 20:42:12 UTC, 1 replies.
- [jira] [Updated] (KAFKA-622) Create mbeans per client - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/16 22:53:12 UTC, 6 replies.
- [jira] [Created] (KAFKA-622) Create mbeans per client - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/16 22:53:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/16 22:57:13 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/16 22:57:14 UTC, 0 replies.
- [jira] [Created] (KAFKA-623) It should be possible to re-create KafkaStreams after an exception, without recreating ConsumerConnector - posted by "Jason Rosenberg (JIRA)" <ji...@apache.org> on 2012/11/16 23:45:11 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries" - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/17 00:19:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/17 00:59:12 UTC, 1 replies.
- [jira] [Updated] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages - posted by "Yang Ye (JIRA)" <ji...@apache.org> on 2012/11/17 01:05:12 UTC, 2 replies.
- [jira] [Commented] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/17 01:27:12 UTC, 0 replies.
- [jira] [Created] (KAFKA-624) Add 07 ConsoleConsumer to validate message content for Migration Tool testcases - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/17 01:27:12 UTC, 0 replies.
- [jira] [Closed] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/17 01:29:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/17 01:29:12 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-624) Add 07 ConsoleConsumer to validate message content for Migration Tool testcases - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/17 01:29:12 UTC, 0 replies.
- [jira] [Updated] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/17 01:33:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/17 02:35:12 UTC, 0 replies.
- [jira] [Closed] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/17 02:35:13 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/17 02:41:12 UTC, 0 replies.
- [jira] [Closed] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/17 02:41:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-612) move shutting down of fetcher thread out of critical path - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 02:04:12 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-612) move shutting down of fetcher thread out of critical path - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 02:04:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-622) Create mbeans per client - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 19:08:58 UTC, 3 replies.
- [jira] [Created] (KAFKA-625) Improve MessageAndMetadata to expose the partition - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 20:10:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-625) Improve MessageAndMetadata to expose the partition - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 23:16:58 UTC, 0 replies.
- [jira] [Closed] (KAFKA-625) Improve MessageAndMetadata to expose the partition - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 23:18:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-133) Publish kafka jar to a public maven repository - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 23:38:59 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-532) Multiple controllers can co-exist during soft failures - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/18 23:50:58 UTC, 0 replies.
- [jira] [Closed] (KAFKA-612) move shutting down of fetcher thread out of critical path - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/19 06:52:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/19 17:51:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-627) Make UnknownTopicOrPartitionException a WARN in broker - posted by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2012/11/19 18:35:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-627) Make UnknownTopicOrPartitionException a WARN in broker - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/19 18:41:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/19 18:43:58 UTC, 1 replies.
- [jira] [Updated] (KAFKA-608) getTopicMetadata does not respect producer config settings - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/19 18:59:57 UTC, 5 replies.
- EasyMock? - posted by Jay Kreps <ja...@gmail.com> on 2012/11/19 23:38:51 UTC, 3 replies.
- [jira] [Created] (KAFKA-630) Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/20 19:56:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-630) Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/20 19:58:58 UTC, 0 replies.
- Re: Kafka REST interface - posted by David Arthur <mu...@gmail.com> on 2012/11/20 22:08:16 UTC, 4 replies.
- AdminTest doesn't shutdown cleanly - posted by Jay Kreps <ja...@gmail.com> on 2012/11/21 04:54:46 UTC, 0 replies.
- Re: Build failed in Jenkins: Kafka-0.8 #113 - posted by Jay Kreps <ja...@gmail.com> on 2012/11/21 05:29:31 UTC, 0 replies.
- [jira] [Updated] (KAFKA-521) Refactor Log subsystem - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/21 05:59:58 UTC, 4 replies.
- Fwd: ASF Board Meeting Summary - November 21, 2012 - posted by Jay Kreps <ja...@gmail.com> on 2012/11/21 23:14:53 UTC, 4 replies.
- [jira] [Commented] (KAFKA-430) Improve the "waitUntilLeaderIsElectedOrChanged" function in TestUtils class - posted by "Jim Plush (JIRA)" <ji...@apache.org> on 2012/11/22 01:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-562) Non-failure System Test Log Segment File Checksums mismatched - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/22 22:56:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-468) String#getBytes is platform dependent - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/22 23:04:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-367) StringEncoder/StringDecoder use platform default character set - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/22 23:04:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-468) String#getBytes is platform dependent - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/22 23:04:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-367) StringEncoder/StringDecoder use platform default character set - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/22 23:04:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-344) migration tool from 0.7 to 0.8 - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/22 23:18:58 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-344) migration tool from 0.7 to 0.8 - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/23 01:40:58 UTC, 0 replies.
- [jira] [Closed] (KAFKA-344) migration tool from 0.7 to 0.8 - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/23 01:40:59 UTC, 0 replies.
- understanding partitions based on wiki example of profile visits - posted by S Ahmed <sa...@gmail.com> on 2012/11/26 04:54:40 UTC, 6 replies.
- subscription - posted by Prasanth J <bu...@gmail.com> on 2012/11/26 06:32:41 UTC, 0 replies.
- Kafka 0.8 trial version - posted by Jun Rao <ju...@gmail.com> on 2012/11/26 18:23:35 UTC, 3 replies.
- trunk and branches update - posted by Jun Rao <ju...@gmail.com> on 2012/11/26 18:42:55 UTC, 0 replies.
- [jira] [Commented] (KAFKA-521) Refactor Log subsystem - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/26 21:24:58 UTC, 8 replies.
- AdminTest is failing on 0.8 - posted by Jay Kreps <ja...@gmail.com> on 2012/11/26 22:03:20 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-544) Retain key in producer and expose it in the consumer - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/26 22:22:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-631) Implement log compaction - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/26 23:30:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-631) Implement log compaction - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/26 23:32:59 UTC, 0 replies.
- HighwaterMarkCheckpoint - posted by Jay Kreps <ja...@gmail.com> on 2012/11/27 01:14:48 UTC, 2 replies.
- [jira] [Created] (KAFKA-632) ProducerRequest should take ByteBufferMessageSet instead of MessageSet - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/27 06:27:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-633) AdminTest.testShutdownBroker fails - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/27 06:43:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-260) Add audit trail to kafka - posted by "Lorenz Knies (JIRA)" <ji...@apache.org> on 2012/11/27 10:39:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-634) ConsoleProducer compresses messages and ignores the --compress flag - posted by "Paul Garner (JIRA)" <ji...@apache.org> on 2012/11/27 19:11:57 UTC, 0 replies.
- [jira] [Created] (KAFKA-635) Producer error when trying to send not displayed unless in DEBUG logging level - posted by "Chris Curtin (JIRA)" <ji...@apache.org> on 2012/11/27 19:37:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-633) AdminTest.testShutdownBroker fails - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/28 01:28:58 UTC, 4 replies.
- [jira] [Created] (KAFKA-636) Make log segment delete asynchronous - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/28 04:53:03 UTC, 0 replies.
- [jira] [Commented] (KAFKA-635) Producer error when trying to send not displayed unless in DEBUG logging level - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/28 06:04:58 UTC, 1 replies.
- Re: git wip incubator-kafka.git - posted by Jun Rao <ju...@gmail.com> on 2012/11/28 07:28:17 UTC, 1 replies.
- Kafka svn repo removed from incubator - posted by Jun Rao <ju...@gmail.com> on 2012/11/28 19:26:56 UTC, 3 replies.
- new location of Kafka repo - posted by Jun Rao <ju...@gmail.com> on 2012/11/28 19:49:08 UTC, 0 replies.
- [jira] [Updated] (KAFKA-632) ProducerRequest should take ByteBufferMessageSet instead of MessageSet - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/28 19:52:59 UTC, 2 replies.
- [jira] [Commented] (KAFKA-632) ProducerRequest should take ByteBufferMessageSet instead of MessageSet - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/28 19:56:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-637) Separate log4j environment variable from KAFKA_OPTS in kafka-run-class.sh - posted by "Chris Curtin (JIRA)" <ji...@apache.org> on 2012/11/28 20:02:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-632) ProducerRequest should take ByteBufferMessageSet instead of MessageSet - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/28 22:05:59 UTC, 0 replies.
- [jira] [Closed] (KAFKA-632) ProducerRequest should take ByteBufferMessageSet instead of MessageSet - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/28 22:07:57 UTC, 0 replies.
- new mailing lists - posted by Jun Rao <ju...@gmail.com> on 2012/11/28 22:12:43 UTC, 5 replies.
- [jira] [Created] (KAFKA-638) remove ProducerShell - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/28 23:33:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-638) remove ProducerShell - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/28 23:35:58 UTC, 2 replies.
- [jira] [Commented] (KAFKA-638) remove ProducerShell - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/28 23:39:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-638) remove ProducerShell - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/29 01:03:59 UTC, 0 replies.
- [jira] [Closed] (KAFKA-638) remove ProducerShell - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/29 01:03:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/29 01:11:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-639) RESTful proxy - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2012/11/29 02:03:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-639) RESTful proxy - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2012/11/29 02:17:59 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-639) RESTful proxy - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2012/11/29 02:18:03 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-622) Create mbeans per client - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/29 02:31:57 UTC, 0 replies.
- [jira] [Closed] (KAFKA-622) Create mbeans per client - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/29 02:31:57 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-637) Separate log4j environment variable from KAFKA_OPTS in kafka-run-class.sh - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2012/11/29 04:48:58 UTC, 0 replies.
- [jira] [Updated] (KAFKA-637) Separate log4j environment variable from KAFKA_OPTS in kafka-run-class.sh - posted by "David Arthur (JIRA)" <ji...@apache.org> on 2012/11/29 04:48:58 UTC, 1 replies.
- Git - posted by David Arthur <mu...@gmail.com> on 2012/11/29 16:25:05 UTC, 1 replies.
- [jira] [Created] (KAFKA-640) System Test Failures : kafka.common.InvalidClientIdException in broker log4j messages - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/29 18:22:59 UTC, 0 replies.
- [jira] [Commented] (KAFKA-628) System Test Failure Case 5005 (Mirror Maker bouncing) - Data Loss in ConsoleConsumer - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/29 20:38:59 UTC, 0 replies.
- [jira] [Updated] (KAFKA-640) System Test Failures : kafka.common.InvalidClientIdException in broker log4j messages - posted by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/11/29 23:06:59 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-633) AdminTest.testShutdownBroker fails - posted by "Joel Koshy (JIRA)" <ji...@apache.org> on 2012/11/29 23:30:58 UTC, 0 replies.
- [jira] [Created] (KAFKA-641) ConsumerOffsetChecker breaks when using dns names x.b.com as opposed to raw public IP for broker. - posted by "Juan Valencia (JIRA)" <ji...@apache.org> on 2012/11/30 00:04:58 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-608) getTopicMetadata does not respect producer config settings - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/30 00:06:58 UTC, 0 replies.
- Protocol documentation draft - posted by Jay Kreps <ja...@gmail.com> on 2012/11/30 00:17:01 UTC, 3 replies.
- [jira] [Commented] (KAFKA-640) System Test Failures : kafka.common.InvalidClientIdException in broker log4j messages - posted by "John Fung (JIRA)" <ji...@apache.org> on 2012/11/30 01:37:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-642) Protocol tweaks for 0.8 - posted by "Jay Kreps (JIRA)" <ji...@apache.org> on 2012/11/30 01:49:58 UTC, 0 replies.
- [jira] [Commented] (KAFKA-608) getTopicMetadata does not respect producer config settings - posted by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/11/30 18:49:58 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-640) System Test Failures : kafka.common.InvalidClientIdException in broker log4j messages - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/30 18:51:58 UTC, 0 replies.
- [jira] [Closed] (KAFKA-640) System Test Failures : kafka.common.InvalidClientIdException in broker log4j messages - posted by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/11/30 18:51:58 UTC, 0 replies.