TAO XIAO created KAFKA-2281:
-------------------------------

             Summary: 
org.apache.kafka.clients.producer.internals.ErrorLoggingCallback holds 
unnecessary byte[] value
                 Key: KAFKA-2281
                 URL: https://issues.apache.org/jira/browse/KAFKA-2281
             Project: Kafka
          Issue Type: Bug
          Components: producer 
    Affects Versions: 0.8.2.1
            Reporter: TAO XIAO
            Assignee: Jun Rao


org.apache.kafka.clients.producer.internals.ErrorLoggingCallback is constructed 
with byte[] value as one of the input. It holds the reference to the value 
until it finishes its lifecycle. The value is not used except for logging its 
size. This behavior causes unnecessary memory consumption.

The fix is to take the size of the value as the input instead of its content



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

Reply via email to