David Stein created KAFKA-870: --------------------------------- Summary: hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller Key: KAFKA-870 URL: https://issues.apache.org/jira/browse/KAFKA-870 Project: Kafka Issue Type: Bug Components: contrib Affects Versions: 0.7 Reporter: David Stein
KafkaRecordWriter incorrectly gets the entire buffer capacity of the input BytesWritable. If the capacity is larger than the underlying represented byte array, then the message will be padded with garbage bytes at the end. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira