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

Posted to dev@kafka.apache.org by "Pratik kumar (JIRA)" <ji...@apache.org> on 2016/12/11 15:48:58 UTC

[jira] [Updated] (KAFKA-4522) Using Disruptor instead of Array Blocking queue in Kafka Producer

     [ https://issues.apache.org/jira/browse/KAFKA-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Pratik kumar updated KAFKA-4522:
--------------------------------
    Description: 
Kafka Producer currently uses Java's Array Blocking Queue to store outbound kafka message before batching them in async mode. 
Usage of LMAX Disruptor can reduce the lock contention overhead put by Kafka Producer.
LMAX Disruptor -> https://github.com/LMAX-Exchange/disruptor

> Using Disruptor instead of Array Blocking queue in Kafka Producer
> -----------------------------------------------------------------
>
>                 Key: KAFKA-4522
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4522
>             Project: Kafka
>          Issue Type: Improvement
>          Components: producer 
>            Reporter: Pratik kumar
>
> Kafka Producer currently uses Java's Array Blocking Queue to store outbound kafka message before batching them in async mode. 
> Usage of LMAX Disruptor can reduce the lock contention overhead put by Kafka Producer.
> LMAX Disruptor -> https://github.com/LMAX-Exchange/disruptor



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)