kafka-dev  

Messages by Thread

• • [jira] [Commented] (KAFKA-464) KafkaController NPE in SessionExpireListener Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-464) KafkaController NPE in SessionExpireListener Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-464) KafkaController NPE in SessionExpireListener Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-464) KafkaController NPE in SessionExpireListener Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-464) KafkaController NPE in SessionExpireListener Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-464) KafkaController NPE in SessionExpireListener Jun Rao (JIRA)
• [jira] [Created] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Joel Koshy (JIRA)
  • [jira] [Assigned] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Swapnil Ghike (JIRA)
  • [jira] [Resolved] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-463) log.truncateTo needs to handle targetOffset smaller than the lowest offset in the log Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-189) Create a script for dump segment tool Pierre Queinnec (JIRA)
  • [jira] [Updated] (KAFKA-189) Create a script for dump segment tool Pierre Queinnec (JIRA)
• Re: Build failed in Jenkins: Kafka-0.8 #19 Neha Narkhede
• [jira] [Created] (KAFKA-462) ZK thread crashing doesn't bring down the broker (and doesn't come back up). Matt Jones (JIRA)
• [jira] [Commented] (KAFKA-313) Add JSON output and looping options to ConsumerOffsetChecker Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-313) Add JSON output and looping options to ConsumerOffsetChecker Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-323) Add the ability to use the async producer in the Log4j appender Jay Kreps (JIRA)
• [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-43) Rebalance to preferred broke with intra-cluster replication support Neha Narkhede (JIRA)
• [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication Neha Narkhede (JIRA)
• [jira] [Closed] (KAFKA-453) follower replica may need to backoff the fetching if leader is not ready yet Jun Rao (JIRA)
• [jira] [Resolved] (KAFKA-453) follower replica may need to backoff the fetching if leader is not ready yet Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-289) reuse topicdata when sending producerrequest Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-344) migration tool from 0.7 to 0.8 Yang Ye (JIRA)
• [jira] [Updated] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-453) follower replica may need to backoff the fetching if leader is not ready yet Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-324) enforce broker.id to be a non-negative integer Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-347) change number of partitions of a topic online Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-347) change number of partitions of a topic online Jun Rao (JIRA)
• [jira] [Commented] (KAFKA-215) Improve system tests for the mirroring code Neha Narkhede (JIRA)
• [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-327) Monitoring and tooling for Kafka replication Joel Koshy (JIRA)
• [jira] [Resolved] (KAFKA-215) Improve system tests for the mirroring code Joel Koshy (JIRA)
• [jira] [Updated] (KAFKA-330) Add delete topic support Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-330) Add delete topic support Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-330) Add delete topic support Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-203) Improve Kafka internal metrics Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-203) Improve Kafka internal metrics Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-203) Improve Kafka internal metrics Jun Rao (JIRA)
• [jira] [Created] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jay Kreps (JIRA)
  • [jira] [Work started] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Assigned] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Swapnil Ghike (JIRA)
  • [jira] [Closed] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-461) remove support for format for magic byte 0 in 0.8 Jun Rao (JIRA)
• [jira] [Created] (KAFKA-460) ControllerChannelManager needs synchronization btw shutdown and add/remove broker Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-460) ControllerChannelManager needs synchronization btw shutdown and add/remove broker Joel Koshy (JIRA)
  • [jira] [Closed] (KAFKA-460) ControllerChannelManager needs synchronization btw shutdown and add/remove broker Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-460) ControllerChannelManager needs synchronization btw shutdown and add/remove broker Jun Rao (JIRA)
• [jira] [Created] (KAFKA-459) KafkaController.RequestSendThread can throw exception on broker socket Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-459) KafkaController.RequestSendThread can throw exception on broker socket Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-459) KafkaController.RequestSendThread can throw exception on broker socket Yang Ye (JIRA)
  • [jira] [Closed] (KAFKA-459) KafkaController.RequestSendThread can throw exception on broker socket Jun Rao (JIRA)
  • [jira] [Resolved] (KAFKA-459) KafkaController.RequestSendThread can throw exception on broker socket Jun Rao (JIRA)
• [jira] [Created] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Joel Koshy (JIRA)
  • [jira] [Assigned] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Work started] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jay Kreps (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Commented] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Swapnil Ghike (JIRA)
  • [jira] [Updated] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
  • [jira] [Closed] (KAFKA-458) remove errorcode from ByteBufferMessageSet Jun Rao (JIRA)
• [jira] [Resolved] (KAFKA-258) Remove broker.id from the broker.list config in the Producer Jun Rao (JIRA)
• [jira] [Resolved] (KAFKA-452) follower replica may need to backoff the fetching if leader is not ready yet Jun Rao (JIRA)
• replication development dashboard Joel Koshy
  • Re: replication development dashboard Joel Koshy
  • Re: replication development dashboard Prashanth Menon
  • Re: replication development dashboard Neha Narkhede
  • Re: replication development dashboard Neha Narkhede
• [jira] [Created] (KAFKA-457) Leader Re-election is broken in rev. 1368092 John Fung (JIRA)
  • [jira] [Updated] (KAFKA-457) Leader Re-election is broken in rev. 1368092 John Fung (JIRA)
  • [jira] [Commented] (KAFKA-457) Leader Re-election is broken in rev. 1368092 Yang Ye (JIRA)
  • [jira] [Resolved] (KAFKA-457) Leader Re-election is broken in rev. 1368092 John Fung (JIRA)
• [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
  • [jira] [Updated] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
• [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Joel Koshy (JIRA)
  • [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
  • [jira] [Updated] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
• [jira] [Assigned] (KAFKA-356) Create a generic Kafka thread class that includes basic boiler plate code of instantiating and shutting down threads cleanly Yang Ye (JIRA)
• Non-blocking socket when queue has no new data Lorenzo Alberton
  • Re: Non-blocking socket when queue has no new data Jun Rao
• [jira] [Assigned] (KAFKA-351) Refactor some new components introduced for replication Jun Rao (JIRA)
• [jira] [Created] (KAFKA-450) Test in sync replica changes due to slow or stuck followers Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-450) Test in sync replica changes due to slow or stuck followers Joel Koshy (JIRA)
• [jira] [Created] (KAFKA-449) Leader election test Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-449) Leader election test John Fung (JIRA)
  • [jira] [Updated] (KAFKA-449) Leader election test John Fung (JIRA)
  • [jira] [Commented] (KAFKA-449) Leader election test Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-449) Leader election test John Fung (JIRA)
  • [jira] [Updated] (KAFKA-449) Leader election test Joel Koshy (JIRA)
  • [jira] [Commented] (KAFKA-449) Leader election test Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-449) Leader election test Neha Narkhede (JIRA)
  • [jira] [Closed] (KAFKA-449) Leader election test Jun Rao (JIRA)
• [jira] [Created] (KAFKA-448) Message replication with failures and varied replication factor Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-448) Message replication with failures and varied replication factor Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-448) Message replication with failures and varied replication factor John Fung (JIRA)
• [jira] [Created] (KAFKA-447) Message replication with failures and multiple partitions and log segments Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-447) Message replication with failures and multiple partitions and log segments Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-447) Message replication with failures and multiple partitions and log segments John Fung (JIRA)
• [jira] [Created] (KAFKA-445) Message replication with failures Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-445) Message replication with failures Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-445) Message replication with failures John Fung (JIRA)
• [jira] [Created] (KAFKA-446) Message replication with failures and varied producer acks Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-446) Message replication with failures and varied producer acks Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-446) Message replication with failures and varied producer acks John Fung (JIRA)
• [jira] [Created] (KAFKA-444) Simple message replication test with multiple partitions and log segments Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-444) Simple message replication test with multiple partitions and log segments Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-444) Simple message replication test with multiple partitions and log segments John Fung (JIRA)
• [jira] [Created] (KAFKA-443) Simple message replication test with multiple partitions Neha Narkhede (JIRA)
  • [jira] [Updated] (KAFKA-443) Simple message replication test with multiple partitions Joel Koshy (JIRA)
  • [jira] [Resolved] (KAFKA-443) Simple message replication test with multiple partitions John Fung (JIRA)
• [jira] [Created] (KAFKA-442) Simple message replication test with varied producer acks Neha Narkhede (JIRA)

• Earlier messages
• Later messages