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)