[
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)
