kafka-dev
Thread
Date
Earlier messages
Messages by Thread
[jira] [Created] (KAFKA-636) Make log segment delete asynchronous
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-635) Producer error when trying to send not displayed unless in DEBUG logging level
Chris Curtin (JIRA)
[jira] [Commented] (KAFKA-635) Producer error when trying to send not displayed unless in DEBUG logging level
Jun Rao (JIRA)
[jira] [Created] (KAFKA-634) ConsoleProducer compresses messages and ignores the --compress flag
Paul Garner (JIRA)
[jira] [Created] (KAFKA-633) AdminTest.testShutdownBroker fails
Jun Rao (JIRA)
[jira] [Commented] (KAFKA-633) AdminTest.testShutdownBroker fails
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-632) ProducerRequest should take ByteBufferMessageSet instead of MessageSet
Jun Rao (JIRA)
HighwaterMarkCheckpoint
Jay Kreps
Re: HighwaterMarkCheckpoint
Jay Kreps
Re: HighwaterMarkCheckpoint
Jay Kreps
[jira] [Created] (KAFKA-631) Implement log compaction
Jay Kreps (JIRA)
[jira] [Commented] (KAFKA-631) Implement log compaction
Jay Kreps (JIRA)
trunk and branches update
Jun Rao
Kafka 0.8 trial version
Jun Rao
Re: Kafka 0.8 trial version
S Ahmed
Re: Kafka 0.8 trial version
Neha Narkhede
Re: understanding partitions based on wiki example of profile visits
S Ahmed
Re: understanding partitions based on wiki example of profile visits
Jay Kreps
Re: understanding partitions based on wiki example of profile visits
S Ahmed
Re: understanding partitions based on wiki example of profile visits
Jay Kreps
Re: understanding partitions based on wiki example of profile visits
S Ahmed
Re: understanding partitions based on wiki example of profile visits
Jay Kreps
subscription
Prasanth J
[jira] [Closed] (KAFKA-344) migration tool from 0.7 to 0.8
Neha Narkhede (JIRA)
[jira] [Resolved] (KAFKA-344) migration tool from 0.7 to 0.8
Neha Narkhede (JIRA)
Fwd: ASF Board Meeting Summary - November 21, 2012
Jay Kreps
Re: ASF Board Meeting Summary - November 21, 2012
Prashanth Menon
Re: ASF Board Meeting Summary - November 21, 2012
David Arthur
Re: ASF Board Meeting Summary - November 21, 2012
chetan conikee
Re: ASF Board Meeting Summary - November 21, 2012
Chris Douglas
Re: Build failed in Jenkins: Kafka-0.8 #113
Jay Kreps
[jira] [Created] (KAFKA-630) Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-630) Auto create topic doesn't reflect the new topic and throws UnknownTopicOrPartitionException
Neha Narkhede (JIRA)
Re: EasyMock?
Derek Chen-Becker
Re: EasyMock?
Joe Stein
Re: EasyMock?
Derek Chen-Becker
[jira] [Created] (KAFKA-627) Make UnknownTopicOrPartitionException a WARN in broker
Chris Riccomini (JIRA)
[jira] [Commented] (KAFKA-627) Make UnknownTopicOrPartitionException a WARN in broker
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests
Neha Narkhede (JIRA)
[jira] [Commented] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests
Neha Narkhede (JIRA)
[jira] [Commented] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests
Jay Kreps (JIRA)
[jira] [Updated] (KAFKA-133) Publish kafka jar to a public maven repository
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-133) Publish kafka jar to a public maven repository
Neha Narkhede (JIRA)
[jira] [Created] (KAFKA-625) Improve MessageAndMetadata to expose the partition
Neha Narkhede (JIRA)
[jira] [Resolved] (KAFKA-625) Improve MessageAndMetadata to expose the partition
Neha Narkhede (JIRA)
[jira] [Closed] (KAFKA-625) Improve MessageAndMetadata to expose the partition
Neha Narkhede (JIRA)
[jira] [Created] (KAFKA-624) Add 07 ConsoleConsumer to validate message content for Migration Tool testcases
John Fung (JIRA)
[jira] [Assigned] (KAFKA-624) Add 07 ConsoleConsumer to validate message content for Migration Tool testcases
John Fung (JIRA)
[jira] [Created] (KAFKA-623) It should be possible to re-create KafkaStreams after an exception, without recreating ConsumerConnector
Jason Rosenberg (JIRA)
[jira] [Created] (KAFKA-622) Create mbeans per client
Swapnil Ghike (JIRA)
[jira] [Updated] (KAFKA-622) Create mbeans per client
Swapnil Ghike (JIRA)
[jira] [Updated] (KAFKA-622) Create mbeans per client
Swapnil Ghike (JIRA)
[jira] [Commented] (KAFKA-622) Create mbeans per client
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-622) Create mbeans per client
Swapnil Ghike (JIRA)
[jira] [Commented] (KAFKA-622) Create mbeans per client
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-622) Create mbeans per client
Swapnil Ghike (JIRA)
[jira] [Created] (KAFKA-621) System Test 9051 : ConsoleConsumer doesn't receives any data for 20 topics but works for 10
John Fung (JIRA)
[jira] [Updated] (KAFKA-621) System Test 9051 : ConsoleConsumer doesn't receives any data for 20 topics but works for 10
John Fung (JIRA)
[jira] [Created] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker
Matthew Rathbone (JIRA)
[jira] [Updated] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker
Matthew Rathbone (JIRA)
[jira] [Commented] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker
Jun Rao (JIRA)
[jira] [Commented] (KAFKA-620) UnknownHostError looking for a ZK node crashes the broker
Neha Narkhede (JIRA)
[jira] [Created] (KAFKA-619) System Test Regression 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B
John Fung (JIRA)
[jira] [Updated] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B
John Fung (JIRA)
[jira] [Updated] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B
John Fung (JIRA)
[jira] [Updated] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B
John Fung (JIRA)
[jira] [Commented] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B
Jay Kreps (JIRA)
[jira] [Resolved] (KAFKA-619) Regression : System Test 900x (Migration Tool) - java.lang.ClassCastException: kafka.message.Message cannot be cast to [B
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure
Joel Koshy (JIRA)
[jira] [Commented] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure
Joel Koshy (JIRA)
[jira] [Commented] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure
Jun Rao (JIRA)
[jira] [Resolved] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure
Joel Koshy (JIRA)
[jira] [Closed] (KAFKA-618) Deadlock between leader-finder-thread and consumer-fetcher-thread during broker failure
Joel Koshy (JIRA)
[jira] [Created] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest
Jay Kreps (JIRA)
[jira] [Commented] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-616) Implement acks=0
Jay Kreps (JIRA)
[jira] [Updated] (KAFKA-616) Implement acks=0
Jay Kreps (JIRA)
[jira] [Updated] (KAFKA-616) Implement acks=0
Neha Narkhede (JIRA)
Can a brother get a +1?
Jay Kreps
[jira] [Created] (KAFKA-615) Avoid fsync on log segment roll
Jay Kreps (JIRA)
[jira] [Commented] (KAFKA-615) Avoid fsync on log segment roll
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages
Yang Ye (JIRA)
[jira] [Updated] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages
Yang Ye (JIRA)
[jira] [Resolved] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages
Jun Rao (JIRA)
[jira] [Closed] (KAFKA-614) DumpLogSegment offset verification is incorrect for compressed messages
Jun Rao (JIRA)
[jira] [Created] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer
Yang Ye (JIRA)
[jira] [Commented] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer
Yang Ye (JIRA)
[jira] [Resolved] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer
Jun Rao (JIRA)
[jira] [Closed] (KAFKA-613) MigrationTool should disable shallow iteration in the 0.7 consumer
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-179) Log files always touched when broker is bounced
Jay Kreps (JIRA)
[jira] [Resolved] (KAFKA-71) embed offset inside Message class
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Assigned] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Commented] (KAFKA-612) move shutting down of fetcher thread out of critical path
Neha Narkhede (JIRA)
[jira] [Comment Edited] (KAFKA-612) move shutting down of fetcher thread out of critical path
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Commented] (KAFKA-612) move shutting down of fetcher thread out of critical path
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Closed] (KAFKA-612) move shutting down of fetcher thread out of critical path
Jun Rao (JIRA)
[jira] [Created] (KAFKA-611) Migration tool and Mirror Maker ignore mirror.topics.whitelist in config
Chris Riccomini (JIRA)
[jira] [Created] (KAFKA-610) connect.timeout.ms seems to do the wrong thing in the producer
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries"
John Fung (JIRA)
[jira] [Commented] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries"
John Fung (JIRA)
[jira] [Commented] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries"
Yang Ye (JIRA)
[jira] [Commented] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries"
Yang Ye (JIRA)
[jira] [Resolved] (KAFKA-609) System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer terminates after "can't rebalance after 4 retries"
Yang Ye (JIRA)
[jira] [Created] (KAFKA-608) getTopicMetadata does not respect producer config settings
Jay Kreps (JIRA)
[jira] [Updated] (KAFKA-608) getTopicMetadata does not respect producer config settings
Jay Kreps (JIRA)
[jira] [Comment Edited] (KAFKA-133) Publish kafka jar to a public maven repository
Otis Gospodnetic (JIRA)
[jira] [Comment Edited] (KAFKA-133) Publish kafka jar to a public maven repository
Otis Gospodnetic (JIRA)
[jira] [Created] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data
John Fung (JIRA)
[jira] [Updated] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data
John Fung (JIRA)
[jira] [Commented] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data
John Fung (JIRA)
[jira] [Commented] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data
John Fung (JIRA)
[jira] [Comment Edited] (KAFKA-607) System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer receives less data
John Fung (JIRA)
[jira] [Created] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas
John Fung (JIRA)
[jira] [Updated] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas
John Fung (JIRA)
[jira] [Commented] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas
John Fung (JIRA)
[jira] [Commented] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas
John Fung (JIRA)
[jira] [Commented] (KAFKA-606) System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched across replicas
Jun Rao (JIRA)
[jira] [Created] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Commented] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
John Fung (JIRA)
[jira] [Updated] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
Jun Rao (JIRA)
[jira] [Closed] (KAFKA-605) System Test - Log Retention Cases should wait longer before getting the common starting offset in replica log segments
Jun Rao (JIRA)
[jira] [Created] (KAFKA-604) Add missing metrics in 0.8
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-604) Add missing metrics in 0.8
Yang Ye (JIRA)
[jira] [Commented] (KAFKA-604) Add missing metrics in 0.8
Joel Koshy (JIRA)
[jira] [Commented] (KAFKA-604) Add missing metrics in 0.8
Joel Koshy (JIRA)
Kafka stream processing framework?
David Arthur
Re: Kafka stream processing framework?
Prashanth Menon
Re: Kafka stream processing framework?
David Arthur
Re: Kafka stream processing framework?
Prashanth Menon
Re: Kafka stream processing framework?
Milind Parikh
Re: Multi Costumer and Broker
David Arthur
[jira] [Created] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Commented] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Updated] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Comment Edited] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Commented] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Commented] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
Joel Koshy (JIRA)
[jira] [Commented] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Resolved] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Closed] (KAFKA-603) System Test Data Validation Failure - Replication Factor less than No. of Broker
John Fung (JIRA)
[jira] [Created] (KAFKA-602) A ConsumerConnector that never receives messages does not shutdown cleanly
Jason Rosenberg (JIRA)
[jira] [Created] (KAFKA-601) ConsumerConnector.shutdown() hangs if autocommit is enabled, and no zk available
Jason Rosenberg (JIRA)
[jira] [Created] (KAFKA-600) kafka should respond gracefully rather than crash when unable to write due to ENOSPC
Tim Stilwell (JIRA)
[jira] [Commented] (KAFKA-600) kafka should respond gracefully rather than crash when unable to write due to ENOSPC
Jay Kreps (JIRA)
[jira] [Closed] (KAFKA-188) Support multiple data directories
Jay Kreps (JIRA)
[jira] [Resolved] (KAFKA-188) Support multiple data directories
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata
John Fung (JIRA)
[jira] [Commented] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata
John Fung (JIRA)
[jira] [Comment Edited] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata
John Fung (JIRA)
[jira] [Comment Edited] (KAFKA-599) SimpleConsumerShell ONLY connects to the first host in the broker-list string to fetch topic metadata
John Fung (JIRA)
[jira] [Created] (KAFKA-598) decouple fetch size from max message size
Jun Rao (JIRA)
[jira] [Assigned] (KAFKA-598) decouple fetch size from max message size
Joel Koshy (JIRA)
[jira] [Created] (KAFKA-597) Refactor KafkaScheduler
Jay Kreps (JIRA)
[jira] [Created] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Jun Rao (JIRA)
[jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Jun Rao (JIRA)
[jira] [Assigned] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Swapnil Ghike (JIRA)
[jira] [Updated] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Swapnil Ghike (JIRA)
[jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Jun Rao (JIRA)
[jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Swapnil Ghike (JIRA)
[jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Swapnil Ghike (JIRA)
[jira] [Updated] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Swapnil Ghike (JIRA)
[jira] [Commented] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Neha Narkhede (JIRA)
[jira] [Resolved] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Jun Rao (JIRA)
[jira] [Closed] (KAFKA-596) LogSegment.firstAppendTime not reset after truncate to
Jun Rao (JIRA)
[jira] [Created] (KAFKA-595) Producer side compression is unnecessary
Neha Narkhede (JIRA)
[jira] [Commented] (KAFKA-595) Producer side compression is unnecessary
Jay Kreps (JIRA)
[jira] [Commented] (KAFKA-595) Producer side compression is unnecessary
Jay Kreps (JIRA)
[jira] [Commented] (KAFKA-595) Producer side compression is unnecessary
Neha Narkhede (JIRA)
[jira] [Updated] (KAFKA-595) Producer side compression is unnecessary
Neha Narkhede (JIRA)
Re: CSV metrics
Jay Kreps
Re: CSV metrics
Joel Koshy
[jira] [Created] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
John Fung (JIRA)
[jira] [Updated] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
John Fung (JIRA)
[jira] [Updated] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
John Fung (JIRA)
[jira] [Commented] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
John Fung (JIRA)
[jira] [Commented] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
Neha Narkhede (JIRA)
[jira] [Closed] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
Jun Rao (JIRA)
[jira] [Updated] (KAFKA-594) Update System Test due to new argument "--sync" in ProducerPerformance
Jun Rao (JIRA)
Earlier messages